Clever Geek Handbook

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
apache-kafka


source to share


No one has answered this question yet

Check out similar questions:

20
Understanding Kafka Topics and Sections
five
Kafka elections lead to the collapse of Kafka
1
Kafka cross-center cluster
1
Why are there no nodes in / controller znode when the Kafka cluster is running?
1
How can I mitigate the impact on associated producers and consumers when restarting the Kafka broker?
1
Major players of Kafka
0
Kafka Communication Inter Broker
0
How to move the section with leader -1 to another broker?
0
Kafka section leaders election failed after uncontrolled broker shutdown
0
kafka consumer does not receive messages after broker leader


More articles:


All Articles
Loading...
X
Show
Funny
Dev
Pics