开发者社区> 问答> 正文

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

展开
收起
古拉古拉 2023-05-08 13:54:21 99 0
2 条回答
写回答
取消 提交回答
  • INFO级别的日志啊,关注WARN级别的日志

    原回答者GitHub用户agapple

    2023-05-09 17:49:36
    赞同 展开评论 打赏
  • 随心分享,欢迎友善交流讨论:)

    根据您的描述,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
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
《MSE 微服务网关》 立即下载
微服务引擎 MSE 治理中心重磅发布 立即下载
阿里云微服务引擎 MSE 2.0 线上发布 立即下载