我也遇到到了问题3, 感觉和数据量突然增大有关系,又好像和机器的CPU有关系。每次我要重启所有kafka消费者服务
这个错误真是太奇怪了,这是集群不正常的表现。你看下集群状态是否正常。
## 查询集群描述
bin/kafka-topics.sh --describe --zookeeper
加入超时设置之后,在consumer或者producer端偶尔会产生
org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition..