[incubator-openwhisk-package-kafka] branch master updated: Specify KafkaProducer API Version to Avoid Lookup (#201)

[be...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new e4cf4c9  Specify KafkaProducer API Version to Avoid Lookup (#201)
e4cf4c9 is described below

commit e4cf4c9b2a13c82f3acb9048a29cc33759753f39
Author: James Dubee <jw...@us.ibm.com>
AuthorDate: Wed Jul 19 14:51:56 2017 -0400

    Specify KafkaProducer API Version to Avoid Lookup (#201)
---
 action/messageHubProduce.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/action/messageHubProduce.py b/action/messageHubProduce.py
index f8aba0d..20dfc7f 100755
--- a/action/messageHubProduce.py
+++ b/action/messageHubProduce.py
@@ -41,6 +41,7 @@ def main(params):
 
     try:
         producer = KafkaProducer(
+            api_version=(0, 10, 1),
             api_version_auto_timeout_ms=15000,
             bootstrap_servers=validatedParams['kafka_brokers_sasl'],
             sasl_plain_username=validatedParams['user'],

-- 
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <co...@openwhisk.apache.org>'].