Make client keepalive interval configurable on pulsar-client-kafka (a…

…pache#5131)
hcxiong · Sep 6, 2019 · 0f40adc · 0f40adc
1 parent f6af696
commit 0f40adc
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/...nt-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/PulsarClientKafkaConfig.java b/...nt-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/PulsarClientKafkaConfig.java
@@ -48,6 +48,8 @@ public class PulsarClientKafkaConfig {
     public static final String CONCURRENT_LOOKUP_REQUESTS = "pulsar.concurrent.lookup.requests";
     public static final String MAX_NUMBER_OF_REJECTED_REQUESTS_PER_CONNECTION = "pulsar.max.number.rejected.request.per.connection";
 
+    public static final String KEEPALIVE_INTERVAL_MS = "pulsar.keepalive.interval.ms";
+
     public static ClientBuilder getClientBuilder(Properties properties) {
         ClientBuilder clientBuilder = PulsarClient.builder();
 
@@ -112,6 +114,11 @@ public static ClientBuilder getClientBuilder(Properties properties) {
                     Integer.parseInt(properties.getProperty(MAX_NUMBER_OF_REJECTED_REQUESTS_PER_CONNECTION)));
         }
 
+        if (properties.containsKey(KEEPALIVE_INTERVAL_MS)) {
+            clientBuilder.keepAliveInterval(Integer.parseInt(properties.getProperty(KEEPALIVE_INTERVAL_MS)),
+                    TimeUnit.MILLISECONDS);
+        }
+
         return clientBuilder;
     }
 }
diff --git a/site2/docs/adaptors-kafka.md b/site2/docs/adaptors-kafka.md
@@ -237,6 +237,7 @@ You can configure Pulsar authentication provider directly from the Kafka propert
 | [`pulsar.use.tcp.nodelay`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setUseTcpNoDelay-boolean-) | `true` | TCP no-delay. |
 | [`pulsar.concurrent.lookup.requests`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setConcurrentLookupRequest-int-) | `50000` | The maximum number of concurrent topic lookups. |
 | [`pulsar.max.number.rejected.request.per.connection`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setMaxNumberOfRejectedRequestPerConnection-int-) | `50` | The threshold of errors to forcefully close a connection. |
+| [`pulsar.keepalive.interval.ms`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientBuilder.html#keepAliveInterval-int-java.util.concurrent.TimeUnit-)| `30000` | Keep alive interval for each client-broker-connection.  |
 
 
 ### Pulsar producer properties