-
Notifications
You must be signed in to change notification settings - Fork 198
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
pump client: compatible with kafka version tidb-binlog && add unit test #139
Conversation
@july2993 @GregoryIan PTAL |
@GregoryIan @july2993 PTAL again |
} | ||
|
||
// NewLocalUnixSelector returns a LocalUnixSelector. | ||
func NewLocalUnixSelector() PumpSelector { |
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.
return LocalUnixSelector type
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.
you mean update comment?
rest LGTM |
are any stability test running? @WangXiangUSTC |
already run a test before @GregoryIan |
can you describe your test or paste a link about it? |
@july2993 PTAL |
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.
rest LGTM
https://internal.pingcap.net/jira/browse/TOOL-718 |
LGTM |
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
… strategy config (#223) * pump client: compatible with kafka version tidb-binlog && add unit test (#139) * pump client: write commit binlog will never return error (#148) * pkg watcher: move watcher from tidb-enterprise-tools (#146) * pump client: increase retry time, and refine some code (#158) * pump client: add initial log function (#165) * pump client: support change select pump's strategy (#221)
What problem does this PR solve?
make pump client compatible with kafka version tidb-binlog
What is changed and how it works?
add binlog socket as args when create pumps client, and if binlog socket is not empty, will always use local pump to write binlog.
Check List
Tests
Related changes