diff --git a/conf/broker.conf b/conf/broker.conf index 2c14e7d6a5f1b..85efa11658992 100644 --- a/conf/broker.conf +++ b/conf/broker.conf @@ -226,7 +226,7 @@ subscriptionTypesEnabled=Exclusive,Shared,Failover,Key_Shared # On KeyShared subscriptions, with default AUTO_SPLIT mode, use splitting ranges or # consistent hashing to reassign keys to new consumers -subscriptionKeySharedUseConsistentHashing=false +subscriptionKeySharedUseConsistentHashing=true # On KeyShared subscriptions, number of points in the consistent-hashing ring. # The higher the number, the more equal the assignment of keys to consumers diff --git a/conf/standalone.conf b/conf/standalone.conf index c289e7240cee5..9a727177df7ba 100644 --- a/conf/standalone.conf +++ b/conf/standalone.conf @@ -138,7 +138,7 @@ subscriptionRedeliveryTrackerEnabled=true # On KeyShared subscriptions, with default AUTO_SPLIT mode, use splitting ranges or # consistent hashing to reassign keys to new consumers -subscriptionKeySharedUseConsistentHashing=false +subscriptionKeySharedUseConsistentHashing=true # On KeyShared subscriptions, number of points in the consistent-hashing ring. # The higher the number, the more equal the assignment of keys to consumers diff --git a/deployment/terraform-ansible/templates/broker.conf b/deployment/terraform-ansible/templates/broker.conf index 07e3c7aded044..b8f741e1b56de 100644 --- a/deployment/terraform-ansible/templates/broker.conf +++ b/deployment/terraform-ansible/templates/broker.conf @@ -162,7 +162,7 @@ subscriptionKeySharedEnable=true # On KeyShared subscriptions, with default AUTO_SPLIT mode, use splitting ranges or # consistent hashing to reassign keys to new consumers -subscriptionKeySharedUseConsistentHashing=false +subscriptionKeySharedUseConsistentHashing=true # On KeyShared subscriptions, number of points in the consistent-hashing ring. # The higher the number, the more equal the assignment of keys to consumers 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 1e93dc53d25b9..98c63c74309ea 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 @@ -570,8 +570,8 @@ public class ServiceConfiguration implements PulsarConfiguration { @FieldContext(category = CATEGORY_POLICIES, doc = "On KeyShared subscriptions, with default AUTO_SPLIT mode, use splitting ranges or " - + "consistent hashing to reassign keys to new consumers") - private boolean subscriptionKeySharedUseConsistentHashing = false; + + "consistent hashing to reassign keys to new consumers (default is consistent hashing)") + private boolean subscriptionKeySharedUseConsistentHashing = true; @FieldContext( category = CATEGORY_POLICIES,