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
你的答案