This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push: new 89b2eff Use available cores for io thread processing (#7689) 89b2eff is described below commit 89b2effee264f93893cb76f773c78db68080850c Author: Sanjeev Kulkarni <sanjee...@gmail.com> AuthorDate: Wed Jul 29 10:36:44 2020 -0700 Use available cores for io thread processing (#7689) Co-authored-by: Sanjeev Kulkarni <sanje...@splunk.com> --- .../org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java index ce03a27..5a60f64 100644 --- a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java +++ b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java @@ -101,6 +101,7 @@ public class ThreadRuntimeFactory implements RuntimeFactory { clientBuilder.enableTlsHostnameVerification(authConfig.isTlsHostnameVerificationEnable()); clientBuilder.tlsTrustCertsFilePath(authConfig.getTlsTrustCertsFilePath()); } + clientBuilder.ioThreads(Runtime.getRuntime().availableProcessors()); return clientBuilder.build(); } return null;