fix: 多个 destination 时的 zk 竞争问题 #68
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Merge pull request withlin#25 from CanalClient/master
update read me
update readme
拆封receiveMessages
the filter argument of subscribe not work as expected. this commit change the subscribe logic, use the filter to subscribe via tcp protocol. if subscribe success, update the connector's field Filter value and also update the panic behavior of act failure action.
fix: subscribe filter not work expected
2. 添加部分注释信息
修改sample的代码
ack时判断成功状态以避免一个会引起崩溃的队列顺序问题
重写了ClusterCanalConnector，增加client高可用
fixed lazyParseEntry模式Message.Raw
fix:import error packege
withlin
added a commit
that referenced
this pull request
Apr 2, 2021
Co-authored-by: Lucas biu <[email protected]>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
fix: 多个 destination 时的 zk 竞争问题 #66