[incubator-openwhisk] branch master updated: Configure the number of network threads for kafka (#3494)

[je...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jeremiaswerner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk.git


The following commit(s) were added to refs/heads/master by this push:
     new 0b20df0  Configure the number of network threads for kafka (#3494)
0b20df0 is described below

commit 0b20df0f725a671f8e51c9e8793116476fd22f76
Author: Vadim Raskin <ra...@gmail.com>
AuthorDate: Wed Mar 28 13:30:29 2018 +0200

    Configure the number of network threads for kafka (#3494)
---
 ansible/group_vars/all               | 2 ++
 ansible/roles/kafka/tasks/deploy.yml | 1 +
 2 files changed, 3 insertions(+)

diff --git a/ansible/group_vars/all b/ansible/group_vars/all
index 3f9507f..cd4eeba 100644
--- a/ansible/group_vars/all
+++ b/ansible/group_vars/all
@@ -116,6 +116,8 @@ kafka:
     port: 8093
   heap: "{{ kafka_heap | default('1g') }}"
   replicationFactor: "{{ kafka_replicationFactor | default((groups['kafkas']|length)|int) }}"
+  # adapt this param for production deployments depending on the number of kafka consumers
+  networkThreads: "{{ kafka_network_threads | default(3) }}"
 
 kafka_connect_string: "{% set ret = [] %}\
                        {% for host in groups['kafkas'] %}\
diff --git a/ansible/roles/kafka/tasks/deploy.yml b/ansible/roles/kafka/tasks/deploy.yml
index 8ae7b72..4467fec 100644
--- a/ansible/roles/kafka/tasks/deploy.yml
+++ b/ansible/roles/kafka/tasks/deploy.yml
@@ -27,6 +27,7 @@
       "KAFKA_ZOOKEEPER_CONNECT": "{{ zookeeper_connect_string }}"
       "KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR": "{{ kafka.replicationFactor }}"
       "KAFKA_AUTO_CREATE_TOPICS_ENABLE": "false"
+      "KAFKA_NUM_NETWORK_THREADS": "{{ kafka.networkThreads }}"
 
 - name: add kafka non-ssl vars
   when: kafka.protocol != 'SSL'

-- 
To stop receiving notification emails like this one, please contact
jeremiaswerner@apache.org.