replace kafka host in flow.xml (if found)

abajwa-hw · Nov 9, 2016 · 3b9d327 · 3b9d327
1 parent d751075
commit 3b9d327
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/package/scripts/params.py b/package/scripts/params.py
@@ -87,6 +87,7 @@
 
 master_configs = config['clusterHostInfo']
 nifi_master_hosts = master_configs['nifi_master_hosts']
+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'])