support dynamic config for replicationProducerQueueSize (apache#13529)

AlphaWang · Jan 13, 2022 · 0648f6b · 0648f6b
1 parent 8a0cfac
commit 0648f6b
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -2046,7 +2046,9 @@ public class ServiceConfiguration implements PulsarConfiguration {
     private String replicatorPrefix = "pulsar.repl";
     @FieldContext(
         category = CATEGORY_REPLICATION,
-        doc = "Replicator producer queue size"
+        dynamic = true,
+        doc = "Replicator producer queue size. "
+                + "When dynamically modified, it only takes effect for the newly added replicators"
     )
     private int replicationProducerQueueSize = 1000;
     @FieldContext(