Is NotLeaderForPartitionException thrown during shutdown of Kafka Broker?
When I perform a Kafka Broker controlled shutdown on a cluster, I see this exception in kafka_root.logs for a short time:
org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition
Is this the expected behavior? I thought that when the Kafka brokers are closed, the group will choose a different broker for each section and inform consumers about it? This is not true?
+3
source to share
No one has answered this question yet
Check out similar questions: