启动group-instance订阅多个数据源到MQ，用zk持久化cursor数据会导致/1001/
背景：
canal自带的group-instance.xml里配置的MemoryLogPositionManager是纯粹基于内存记录logPosition，不满足HA；
问题：
将group-instance.xml里的MemoryLogPositionManager替换成FailbackLogPositionManager配置，会导致zk的/otter/canal/destinations/{dest}/1001/cursor数据被多个eventParser争抢覆盖
求解答：
如何对每个eventParser（即多个数据源）分别创建各自的cursor节点，让各自的logPosition互不影响
看源码里CanalMQStarter创建ClientIdentity的时候把clientId写死成1001了，这样对于groupEventParser模式来讲是个bug吧。
原提问者GitHub用户yourse007
展开
收起
1
条回答
写回答
写回答
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
