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