-
Notifications
You must be signed in to change notification settings - Fork 286
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Feature/sink canal protocol #649
Feature/sink canal protocol #649
Conversation
update fork
To pass the ci check
/run-integration-tests |
Codecov Report
@@ Coverage Diff @@
## master #649 +/- ##
================================================
+ Coverage 32.4923% 33.0177% +0.5254%
================================================
Files 84 87 +3
Lines 8482 8768 +286
================================================
+ Hits 2756 2895 +139
- Misses 5512 5646 +134
- Partials 214 227 +13 |
@@ -0,0 +1,154 @@ | |||
syntax = "proto3"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Could you add Alibaba Apache-2.0 license header?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
added in pingcap/ticdc@01a5a3e
@@ -0,0 +1,230 @@ | |||
syntax = "proto3"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Could you add Alibaba Apache-2.0 license header?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
added in pingcap/ticdc@01a5a3e
add warning log for unsupported EventBatchEncoder protocol reorder the imports in cdc/sink/codec/interface.go
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
/run-integration-tests |
/run-integration-tests |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
What problem does this PR solve?
support canal protocol in mqSink
https://github.com/pingcap/ticdc/issues/607
What is changed and how it works?
implements the EventBatchEncoder interface by CanalEventBatchEncoder
Tests
Release note