现场collector生产kafka消息报： NOT_LEADER_FOR_PARTITION 错误，错误位置：org.apache.kafka.client.internal.Sender中298行
kafka server.log报 That server is not the leader of this partition
问题原因： broker意外停止或执行bin/kafka-preferred-replica-election.sh重新对主题leader发生过重新选举导致主题leader节点发生变更
重建topic/重启kafka/重启collector 未生效
以下场景未尝试
配置colellector producer retries参数为3
https://www.iteye.com/blog/kelgon-2287558
清除collector下connect.offsets文件重启collector
清除kafka/kafka-data目录数据， 清除zk 上/kafka节点，重建topic
版权声明：本文为wangweidong_hb原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。