Use available cores for io thread processing (apache#7689)

Co-authored-by: Sanjeev Kulkarni <[email protected]>
liangyali · Jul 29, 2020 · 89b2eff · 89b2eff
1 parent 292fef6
commit 89b2eff
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...untime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java b/...untime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java
@@ -101,6 +101,7 @@ && isNotBlank(authConfig.getClientAuthenticationParameters())) {
                 clientBuilder.enableTlsHostnameVerification(authConfig.isTlsHostnameVerificationEnable());
                 clientBuilder.tlsTrustCertsFilePath(authConfig.getTlsTrustCertsFilePath());
             }
+            clientBuilder.ioThreads(Runtime.getRuntime().availableProcessors());
             return clientBuilder.build();
         }
         return null;