Ron Dagostino created KAFKA-14887:
-------------------------------------
Summary: ZK session timeout can cause broker to shutdown
Key: KAFKA-14887
URL: https://issues.apache.org/jira/browse/KAFKA-14887
Project: Kafka
Issue Type: Improvement
Affects Versions: 3.3.2, 3.3.1, 3.2.3, 3.2.2, 3.4.0, 3.2.1, 3.1.2, 3.0.2,
3.3.0, 3.1.1, 3.2.0, 2.8.2, 3.0.1, 3.0.0, 2.8.1, 2.7.2, 3.1.0, 2.7.1, 2.8.0,
2.7.0
Reporter: Ron Dagostino
We have the following code in FinalizedFeatureChangeListener.scala which will
exit regardless of the type of exception that is thrown when trying to process
feature changes:
case e: Exception => {
error("Failed to process feature ZK node change event. The broker
will eventually exit.", e)
throw new FatalExitError(1)
The issue here is that this does not distinguish between exceptions caused by
an inability to process a feature change and an exception caused by a ZooKeeper
session timeout. We want to shut the broker down for the former case, but we
do NOT want to shut the broker down in the latter case; the ZooKeeper session
will eventually be reestablished, and we can continue processing at that time.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
