请问kafka报"__consumer_offsets" notleaderforpartitionexception 异常是什么原因造成的?参数设置的不合理?

傲月 发表于: 2016-09-13   最后更新时间: 2016-09-13 12:19:38   9,202 游览
kafka
发表于 2016-09-13
傲月
添加评论

notLeaderForPartitionException是说没有找到该分区的leader。

0.9+的kafka版本，offset默认存储__consumer_offsets，你可以通过命令检查下集群节点是否正常。

回复
回答于 8年前
無名
傲月 -> 無名 8年前

不好意思,刚才忘说了,我用的版本是0.8.2的.
我看官网上写的0.8.2的也会用到__consumer_offsets.
然后我用kafka-preferred-replica-election.sh --zookeeper localhost:2181重新分布了下.
在重新之前查了下,leader和isr都是不均匀的.重新分布后,查了下,还是不均匀.并且notleaderforpartitionexception还在报.

0 0 回复
傲月 -> 傲月 8年前

查看状态时,有这样的情况: Replicas: 1,5,2 Isr: 5,2, ISR与备份不致.

执行kafka-preferred-replica-election.sh这个命令后,还不一致.

0 0 回复
無名 -> 傲月 8年前

重启下集群试试

0 0 回复
傲月 -> 無名 8年前

因为数据量很大,有没有可能是num.replica.fetchers开的太小了.导致follower从ISR中频繁被移除.

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。