现象:
当使用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同步数据到下游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 天后被自动关闭。不再允许新回复。