Note:
This topic has been translated from a Chinese forum by GPT and might contain errors.Original topic: drainer异常退出：fail to push msg to kafka after 30s, check if kafka is up and working，且不会自动重启
|
username: SWCloud
There are 5 drainer nodes in the production environment.
One of the drainer nodes always exits abnormally and does not automatically restart after each exit.
The error in the log is: [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
Additionally, there are no “receive big binlog” keywords found in the log, and other drainer nodes are working normally.
How can I troubleshoot the specific cause of this situation, and why doesn’t the drainer retry after an abnormal exit?
drainer.log.log (5.8 MB)
|
username: