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





All Articles