From b9fe981222af2b831f29a6ef9e6e1ec8f39e2b65 Mon Sep 17 00:00:00 2001 From: fengyubiao Date: Mon, 8 Jul 2024 18:30:39 +0800 Subject: [PATCH] [fix][broker]Change default behavior when ZK session expired to shutdown --- conf/broker.conf | 2 +- .../java/org/apache/pulsar/broker/ServiceConfiguration.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/conf/broker.conf b/conf/broker.conf index 5c5d8d42817e9..773bb8e05279c 100644 --- a/conf/broker.conf +++ b/conf/broker.conf @@ -645,7 +645,7 @@ maxNumPartitionsPerPartitionedTopic=0 # There are two policies to apply when broker metadata session expires: session expired happens, "shutdown" or "reconnect". # With "shutdown", the broker will be restarted. # With "reconnect", the broker will keep serving the topics, while attempting to recreate a new session. -zookeeperSessionExpiredPolicy=reconnect +zookeeperSessionExpiredPolicy=shutdown # Enable or disable system topic systemTopicEnabled=true diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java index 73bf2316b8287..be880c93e53a5 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java @@ -1414,7 +1414,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece + " With \"shutdown\", the broker will be restarted.\n\n" + " With \"reconnect\", the broker will keep serving the topics, while attempting to recreate a new session." ) - private MetadataSessionExpiredPolicy zookeeperSessionExpiredPolicy = MetadataSessionExpiredPolicy.reconnect; + private MetadataSessionExpiredPolicy zookeeperSessionExpiredPolicy = MetadataSessionExpiredPolicy.shutdown; @FieldContext( category = CATEGORY_SERVER,