Update params.py

fixed failure on cluster without kafka
abajwa-hw · Apr 14, 2017 · aa475b9 · aa475b9
1 parent a3cc932
commit aa475b9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/package/scripts/params.py b/package/scripts/params.py
@@ -93,7 +93,7 @@
 
 master_configs = config['clusterHostInfo']
 nifi_master_hosts = master_configs['nifi_master_hosts']
-kafka_broker_host = str(master_configs['kafka_broker_hosts'][0])
+# kafka_broker_host = str(master_configs['kafka_broker_hosts'][0])
 
 # detect if running in single (sandbox) box
 nifi_num_nodes = len(master_configs['nifi_master_hosts'])