Hello,

I am running 3 brokers, one zookeeper and producer all on separate machine. I 
am also sending very low load around 6K msg/sec. Each msg is around 150 bytes 
only.
I ran the load for only 5 minutes and during this time, I see leadership 
chained very often.

I created 3 partitions.

Here leadership for each partitions changed.  All 3 brokers are running 
perfectly fine. No broker is down. Could someone let me know why kafka 
leadership changed very often.

Initially:

Topic:mmetopic1PartitionCount:3 ReplicationFactor:3 Configs:

Topic: mmetopic1Partition: 0 Leader: 2Replicas: 2,3,1 Isr: 2,3,1

Topic: mmetopic1Partition: 1 Leader: 3Replicas: 3,1,2 Isr: 3,1,2

Topic: mmetopic1Partition: 2 Leader: 1Replicas: 1,2,3 Isr: 1,2,3


Changed to:


Topic:mmetopic1PartitionCount:3 ReplicationFactor:3 Configs:

Topic: mmetopic1Partition: 0 Leader: 3Replicas: 2,3,1 Isr: 3,1,2

Topic: mmetopic1Partition: 1 Leader: 3Replicas: 3,1,2 Isr: 3,1,2

Topic: mmetopic1Partition: 2 Leader: 1Replicas: 1,2,3 Isr: 1,3,2


Changed to:


Topic:mmetopic1PartitionCount:3 ReplicationFactor:3 Configs:

Topic: mmetopic1Partition: 0 Leader: 1Replicas: 2,3,1 Isr: 1,2,3

Topic: mmetopic1Partition: 1 Leader: 1Replicas: 3,1,2 Isr: 1,2,3

Topic: mmetopic1Partition: 2 Leader: 2Replicas: 1,2,3 Isr: 2,1,3

Changed to:


Topic:mmetopic1PartitionCount:3 ReplicationFactor:3 Configs:

Topic: mmetopic1Partition: 0 Leader: 3Replicas: 2,3,1 Isr: 3,1,2

Topic: mmetopic1Partition: 1 Leader: 3Replicas: 3,1,2 Isr: 3,1,2

Topic: mmetopic1Partition: 2 Leader: 1Replicas: 1,2,3 Isr: 1,3,2


Thanks,
Lokesh

Reply via email to