make bookkeeper throttle Configurable (apache#7901)

Motivation This PR makes bookkeeper throttle value Configurable
instructure · Sep 9, 2020 · fe621a6 · fe621a6
1 parent e72b0f7
commit fe621a6
Show file tree

Hide file tree

Showing 2 changed files with 7 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
@@ -1082,6 +1082,12 @@ public class ServiceConfiguration implements PulsarConfiguration {
     )
     private boolean bookkeeperClientExposeStatsToPrometheus = false;
 
+    @FieldContext(
+            category = CATEGORY_STORAGE_BK,
+            doc = "Throttle value for bookkeeper client"
+    )
+    private int bookkeeperClientThrottleValue = 0;
+
     /**** --- Managed Ledger --- ****/
     @FieldContext(
         minValue = 1,

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
@@ -106,7 +106,7 @@ ClientConfiguration createBkClientConfiguration(ServiceConfiguration conf) {
             bkConf.setTLSTrustStorePasswordPath(conf.getBookkeeperTLSTrustStorePasswordPath());
         }
 
-        bkConf.setThrottleValue(0);
+        bkConf.setThrottleValue(conf.getBookkeeperClientThrottleValue());
         bkConf.setAddEntryTimeout((int) conf.getBookkeeperClientTimeoutInSeconds());
         bkConf.setReadEntryTimeout((int) conf.getBookkeeperClientTimeoutInSeconds());
         bkConf.setSpeculativeReadTimeout(conf.getBookkeeperClientSpeculativeReadTimeoutInMillis());