reconnect broker when ZooKeeper session expires

apache · Dec 17, 2021 · 6291089 · 6291089
1 parent 703712e
commit 6291089
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/conf/broker.conf b/conf/broker.conf
@@ -537,8 +537,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.
-# Node: the "reconnect" policy is an experiment feature
-zookeeperSessionExpiredPolicy=shutdown
+zookeeperSessionExpiredPolicy=reconnect
 
 # Enable or disable system topic
 systemTopicEnabled=false

diff --git a/deployment/terraform-ansible/templates/broker.conf b/deployment/terraform-ansible/templates/broker.conf
@@ -424,8 +424,7 @@ maxNumPartitionsPerPartitionedTopic=0
 # There are two policies when zookeeper session expired happens, "shutdown" and "reconnect".
 # If uses "shutdown" policy, shutdown the broker when zookeeper session expired happens.
 # If uses "reconnect" policy, try to reconnect to zookeeper server and re-register metadata to zookeeper.
-# Node: the "reconnect" policy is an experiment feature
-zookeeperSessionExpiredPolicy=shutdown
+zookeeperSessionExpiredPolicy=reconnect
 
 # Enable or disable system topic
 systemTopicEnabled=false

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
@@ -1100,7 +1100,7 @@ public class ServiceConfiguration implements PulsarConfiguration {
         + " 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.shutdown;
+    private MetadataSessionExpiredPolicy zookeeperSessionExpiredPolicy = MetadataSessionExpiredPolicy.reconnect;
 
     @FieldContext(
         category = CATEGORY_SERVER,