drainer异常退出:fail to push msg to kafka after 30s, check if kafka is up and working,且不会自动重启

生产环境中有5个drainer节点
其中有个drainer节点总是异常退出,每次退出后也不会自动重启

检查日志中报错:[ERROR] [syncer.go:538] [“Failed to close syncer”] [error=“fail to push msg to kafka after 30s, check if kafka is up and working”] [errorVerbose="fail to push msg to kafka after 30s, check if kafka is up and working

另外日志中也未发现有recive big binlog关键词,其他drainer节点都是正常工作的。
这种情况如何排查具体原因呢,另外异常退出后的drainer为什么不会重试呢?

drainer.log.log (5.8 MB)

换成 CDC…


5.X 都不兼容,何况你都在用6.x了…