[incubator-openwhisk-package-kafka] branch master updated: Replace 'kafka_brokers_sasl' with the (correct) 'brokers' (#212)

[cs...@apache.org]

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

csantanapr 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 885954e  Replace 'kafka_brokers_sasl' with the (correct) 'brokers' (#212)
885954e is described below

commit 885954e98ec7c6c34caf4c5a957dd52bc2fae3ac
Author: Justin Berstler <bj...@us.ibm.com>
AuthorDate: Fri Aug 11 19:28:26 2017 -0400

    Replace 'kafka_brokers_sasl' with the (correct) 'brokers' (#212)
    
    'kafka_brokers_sasl' is only valid in the messageHubProduce action. The equivalent for kafkaProduce is just 'brokers'
---
 action/kafkaProduce.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/action/kafkaProduce.py b/action/kafkaProduce.py
index 27e177c..95761d0 100644
--- a/action/kafkaProduce.py
+++ b/action/kafkaProduce.py
@@ -195,7 +195,7 @@ def getProducer(validatedParams, timeout_ms):
 
 def getConnectionHash(params):
     # always use the sorted brokers to combat the effects of shuffle()
-    brokers = params['kafka_brokers_sasl']
+    brokers = params['brokers']
     brokers.sort()
     brokersString = ",".join(brokers)
 

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