kafka生产应用中出现NotLeaderOrFollowerException，该如何解决？

小夕夕 发表于: 2022-03-14   最后更新时间: 2022-03-14 23:19:01   5,394 游览

kafka版本：kafka_2.11-1.1.1

近期线上总是会出现以下错误：

org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.

从网上搜索了下，类似情况比较少，有的说是没有建topic/副本/分区情况，但和我目前情况不一致。希望能在这里得到答案。

集群描述：

Topic:risk_gateway_receive      PartitionCount:3        ReplicationFactor:2     Configs:
Topic: risk_gateway_receive     Partition: 0    Leader: 1       Replicas: 1,2   Isr: 1,2
Topic: risk_gateway_receive     Partition: 1    Leader: 2       Replicas: 2,0   Isr: 0,2
Topic: risk_gateway_receive     Partition: 2    Leader: 0       Replicas: 0,1   Isr: 0,1
  • 你情况有啥不一致的？你执行describe命令一下你这个topic的情况，不能让我们靠猜吧。半兽人 2年前 回复
    @半兽人 实际情况是，这个集群已经跑了2年了，发送和消费也没怎么变过。就是最近出现的这个问题，小夕夕 回复
  • 出现这个异常的原因，大概是什么情况下影响的小夕夕 2年前 回复
    @小夕夕 一般这种情况只有broker崩溃才会出现，去broker日志里看看有什么异常。半兽人 回复
    @半兽人 那一时刻，broker日志有很多类似的这种： ``` Member risk-gateway-0-cea49036-ef2d-4a35-83a6-ef33a2e4645d in group risk-gateway has failed 。。。 Member consumer-risk-insight-22-23cf4820-ca1d-4c6b-b8b2-d2dc015f6d59 in group risk-insight has failed。。。 ``` 小夕夕 回复
添加评论
你的答案

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

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