ticdc链接kafka报错

现象:
当使用ticdc同步数据到下游kafka时,任务一致正常跑着,当下游kafka集群添加一个异地的节点时,ticdc任务就开始间断性报错:
error=“[CDC:ErrKafkaNewSaramaProducer]new sarama producer: read tcp 10.108.182.13:46532->10.55.164.14:9092: i/o timeout”

kafka去掉这个异地节点后,任务恢复正常,不再报错。两地的网络延迟大概50ms左右。

这个报错大概率就是网络连通性有问题,请检查TiCDC各个节点到这个新节点的网络链路的问题

当时在cdc节点试了到10.55这个的网络联通性,没问题

要测试所有cdc节点到目标Kafka的网络,还有changefeed创建命令机器到Kafka的网络

都测试了,没有问题

那这个10.108.182.13地址是啥地址啊

这是cdc节点的地址,同时也是tiup所在地址

那不知道为啥了,看报错就是网络问题

看一下有没有超时的参数,可以适当加大一点试试

防火墙和端口也都确认是通的?

通的,测试过了

此话题已在最后回复的 60 天后被自动关闭。不再允许新回复。