zookeeper部分报错
配置都是正常的，启动canal之后，日志也正常
2019-03-05 16:09:37.801 [main] INFO com.alibaba.otter.canal.deployer.CanalController - ## start the canal server[10.11.108.205:11111] 2019-03-05 16:09:38.868 [main] WARN o.s.beans.GenericTypeAwarePropertyDescriptor - Invalid JavaBean property 'connectionCharset' being accessed! Ambiguous write methods found next to actually used [public void com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setConnectionCharset(java.nio.charset.Charset)]: [public void com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setConnectionCharset(java.lang.String)] 2019-03-05 16:09:38.905 [main] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - --> init table filter : ^canal.instance.filter.regex=db_base_info_01.bi_qty_sn_ref$|^db_base_info_01.bi_sales_entity_account_list$|^db_base_info_01.bi_sales_entity_brand_ref$|^db_base_info_01.bi_sales_entity$|^db_base_info_01.bi_sales_entity$ 2019-03-05 16:09:38.905 [main] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - --> init table black filter : 2019-03-05 16:09:38.976 [main] INFO com.alibaba.otter.canal.deployer.CanalStater - ## the canal server is running now ...... 2019-03-05 16:09:39.023 [destination = yyuu , address = /10.11.108.205:3306 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - ---> begin to find start position, it will be long time for reset or first position 2019-03-05 16:09:39.024 [destination = yyuu , address = /10.11.108.205:3306 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - prepare to find start position just show master status 2019-03-05 16:09:39.047 [destination = yyuu , address = /10.11.108.205:3306 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - ---> find start position successfully, EntryPosition[included=false,journalName=mysql-bin.000231,position=11576882,serverId=,gtid=,timestamp=] cost : 3ms , the next step is binlog dump
然后投递不到kafka里面，我看了下zk的日志 2019-03-05 16:09:37,753 [myid:1] - INFO [ProcessThread(sid:1 cport:-1)::PrepRequestProcessor@627] - Got user-level KeeperException when processing sessionid:0x2694cd29f000001 type:create cxid:0x1 zxid:0x2000005f2 txntype:-1 reqpath:n/a Error Path:/otter/canal/destinations Error:KeeperErrorCode = NodeExists for /otter/canal/destinations 2019-03-05 16:09:37,768 [myid:1] - INFO [ProcessThread(sid:1 cport:-1)::PrepRequestProcessor@627] - Got user-level KeeperException when processing sessionid:0x2694cd29f000001 type:create cxid:0x2 zxid:0x2000005f3 txntype:-1 reqpath:n/a Error Path:/otter/canal/cluster Error:KeeperErrorCode = NodeExists for /otter/canal/cluster 2019-03-05 16:09:37,858 [myid:1] - INFO [ProcessThread(sid:1 cport:-1)::PrepRequestProcessor@627] - Got user-level KeeperException when processing sessionid:0x2694cd29f000001 type:create cxid:0x5 zxid:0x2000005f6 txntype:-1 reqpath:n/a Error Path:/otter/canal/destinations/yyuu/cluster/10.11.108.205:11111 Error:KeeperErrorCode = NodeExists for /otter/canal/destinations/yyuu/cluster/10.11.108.205:11111
我尝试了删除目录的方法，也没用，只要已启动canal，zk这里就报已存在。。。我关闭canal，再去看zk发现也没有这个yyuu的目录啊。难道要删除整个destination吗？
原提问者GitHub用户ZSH9053
写回答
-
-
随心分享，欢迎友善交流讨论：）根据您的描述，Canal 启动时您遇到了两个问题：
日志中没有任何错误，但是 Canal 投递不到 Kafka 中。 ZooKeeper 报错，提示节点已存在。 针对这两个问题，您可以尝试以下解决方案：
检查 Canal 是否正确配置了 Kafka。在 Canal 的配置文件中，您需要确保正确配置了 Canal 的 Kafka 相关参数，例如 canal.mq.servers、canal.mq.topic、canal.mq.dynamicTopic、canal.mq.partitions 等。如果这些参数没有正确配置，将会导致 Canal 投递不到 Kafka 中。
尝试删除 ZooKeeper 中的 Canal 节点。您可以使用 ZooKeeper 的客户端工具（例如 zkCli.sh）连接 ZooKeeper，然后删除 Canal 相关的节点。在删除 Canal 节点时，您需要注意不要删除整个 ZooKeeper 目录，只删除 Canal 相关的节点即可。例如，您可以使用以下命令删除 Canal 的目录：
deleteall /otter/canal 请注意，这将删除 Canal 在 ZooKeeper 中的所有相关节点，包括所有的 destination 节点和 cluster 节点。因此，您需要在删除之前确保已经备份了 ZooKeeper 数据，并且不会影响其他应用程序的正常运行。
如果您尝试了以上方法后仍然无法解决问题，您可以提供更多细节信息，例如 Canal 和 Kafka 的版本、操作系统、日志文件等，以便我们更好地帮助您解决问题。
2023-05-08 14:04:16赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
