canal 1.1.5搭建zookeeper3.4.14 后,位点已经记录到zookeeper里面但是通过zkCli.sh get /otter/canal/destinations/example/1001/cussor却看不到位点信息?哪位大佬知道怎么回事?
gzjq41n41#
p5fdfcr12#
@HZLHZLHZL 大佬,你这个解决了嘛,我在test环境也没有路径,连 /otter路径都没有,明明是一个集群./zkCli -server {从canal admin集群配置里面拿到的zk配置}ls / 可以看到其他路径,唯独没有otter
jogvjijk3#
我这边问题原因都是出在canal admin“集群配置”,具体如下:1.canal.zkServers = 空着了,导致zk里面没有/otter 节点
2.错误使用了file而非default,导致没有/otter/canal/destinations/{instance}/ 下面没有1001节点 [https://github.com/https://github.com/ /issues/2739 ] 参考这个canal.instance.global.spring.xml = classpath:spring/file-instance.xml #这个是“错误”,保存位点到文件而非zk#canal.instance.global.spring.xml = classpath:spring/default-instance.xml #zk应该使用这个配置
3条答案
按热度按时间gzjq41n41#
p5fdfcr12#
@HZLHZLHZL 大佬,你这个解决了嘛,我在test环境也没有路径,连 /otter路径都没有,明明是一个集群
./zkCli -server {从canal admin集群配置里面拿到的zk配置}
ls / 可以看到其他路径,唯独没有otter
jogvjijk3#
我这边问题原因都是出在canal admin“集群配置”,具体如下:
1.canal.zkServers = 空着了,导致zk里面没有/otter 节点
2.错误使用了file而非default,导致没有/otter/canal/destinations/{instance}/ 下面没有1001节点 [https://github.com/https://github.com/ /issues/2739 ] 参考这个
canal.instance.global.spring.xml = classpath:spring/file-instance.xml #这个是“错误”,保存位点到文件而非zk
#canal.instance.global.spring.xml = classpath:spring/default-instance.xml #zk应该使用这个配置