1.分库情况下总共10个库,配置了group-instance.xml。
2.有一个客户端来消费这些数据。
3.消费完了之后,服务端写cursor,在这个节点。/otter/canal/destinations/example/1001/cursor。格式化如下:{"@type":"com.alibaba.otter.canal.protocol.position.LogPosition","identity":{"slaveId":-1,"sourceAddress":{"address":"10.20.144.15","port":3306}},"postion":{"included":false,"journalName":"mysql-bin.002253","position":2574756,"timestamp":1363688722000}}
4.请问我总共配置了10个库,分别都消费了,这个在zk是怎么存储的呢?目前在zk中的cursor节点貌似只存储了一个吧
原提问者GitHub用户zhangjun0x01
在分库情况下,每个库都会有一个对应的canal实例,每个实例都会有一个对应的cursor节点来记录消费位置。在zk中的存储方式是在每个实例的节点下面,存储各自的cursor节点。例如,在示例中,节点路径为/otter/canal/destinations/example/1001/cursor,表示的是实例1001的消费位置。如果有多个实例,就会有多个类似的路径。因此,在zk中会存储所有实例的cursor节点,而不是只有一个。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。