Hi,
Problem: A replica for a partition is not coming up. Steps below;
I have a zookeeper cluster with three machines and a kafka cluster with 3
brokers on the same machine.
I created a topic test as below.
Operation: kafka-topics.sh --zookeeper rh3:2181/kafka --create --topic test
--replication-factor 2 --partitions 1
Step 1
Status: kafka-topics.sh --zookeeper rh3:2181/kafka --describe
Topic:test PartitionCount:1 ReplicationFactor:2
Configs:
Topic: test Partition: 0 Leader: 5
Replicas: 5,4 Isr: 5,4
Later i altered the topic to add a new partition:
Step 2:
Operation: kafka-topics.sh --zookeeper rh3:2181/kafka --alter --topic test
--partitions 2
Status: kafka-topics.sh --zookeeper rh3:2181/kafka --describe
Topic:test PartitionCount:2 ReplicationFactor:2
Configs:
Topic: test Partition: 0 Leader: 5
Replicas: 5,4 Isr: 5,4
Topic: test Partition: 1 Leader: 3
Replicas: 3,4 Isr: 3,4
Step 3: now i shutdown broker 4
Status: kafka-topics.sh --zookeeper rh3:2181/kafka --describe
Topic:test PartitionCount:2
ReplicationFactor:2 Configs:
Topic: test Partition: 0 Leader: 5
Replicas: 5,4 Isr: 5
Topic: test Partition: 1 Leader: 3
Replicas: 3,4 Isr: 3
Steep 4: Later, when i got broker up and running. The replica for partition 1
is not syncing up. Here is the status.
Status: kafka-topics.sh --zookeeper rh3:2181/kafka --describe
Topic:test PartitionCount:2
ReplicationFactor:2 Configs:
Topic: test Partition: 0 Leader: 5
Replicas: 5,4 Isr: 5,4
Topic: test Partition: 1 Leader: 3
Replicas: 3,4 Isr: 3
Log in broker 4 shows me this error. could you please let me know what could be
done restore the replica for partition 1.
[2018-08-01 06:02:18,685] INFO [ReplicaFetcher replicaId=4, leaderId=3,
fetcherId=0] Retrying leaderEpoch request for partition test-1 as the leader
reported an error: NOT_LEADER_FOR_PARTITION (kafka.server.ReplicaFetcherThread)
[2018-08-01 06:02:19,690] INFO [ReplicaFetcher replicaId=4, leaderId=3,
fetcherId=0] Retrying leaderEpoch request for partition test-1 as the leader
reported an error: NOT_LEADER_FOR_PARTITION (kafka.server.ReplicaFetcherThread)
Thanks
Manjunath