Hi all, My kafka version is 2.11_0.10.1.0, and clusters have three nodes. I created a topic (3 replications, 6 partitions). And I tested the class ProducerPerformance by using the command like this: bin/kafka-run-class.sh org.apache.kafka.tools.ProducerPerformance --topic test --num-records 2000000 --record-size 10000 --throughput -1 --producer-props bootstrap.servers=“hw167:9092" buffer.memory=67108864 batch.size=8192 acks=1
I ran this command on two nodes at the same time, so they were executed in parallel. And I got a lot of NotLeaderForPartitionException, it said that This server is not the leader for that topic-partition. I know it’s just the warning and finished successfully in the end, but it cost so much time to rebalance the partition. I wonder know what caused this problem? Does the leader of the partition breaker down? (By the way, the kafka is always alive) What made them down? How to fix it? org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. … so much .. Thanks.