Passes the kafka brkoer to the HB sender

IntegratedAlarmSystem-Group · Jun 18, 2018 · 5f60e8e · 5f60e8e
1 parent 457c9f9
commit 5f60e8e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java b/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java
@@ -197,16 +197,18 @@ public static void main(String[] args) {
 			printUsage(options);
 			System.exit(-5);
 		}
+
+		String kafkaBroker = pluginConfig.getSinkServer()+":"+pluginConfig.getSinkPort();
 
-		logger.info("Kafka server {}:{}", pluginConfig.getSinkServer(),pluginConfig.getSinkPort());
+		logger.info("Kafka broker {}", kafkaBroker);
 		MonitorPointSender mpSender = new KafkaPublisher(
 				pluginConfig.getId(), 
 				pluginConfig.getMonitoredSystemId(), 
 				pluginConfig.getSinkServer(), 
 				pluginConfig.getSinkPort(), 
 				Plugin.getScheduledExecutorService());
 
-		HbProducer hbProducer = new HbKafkaProducer(pluginConfig.getId()+"HBSender", new HbJsonSerializer());
+		HbProducer hbProducer = new HbKafkaProducer(pluginConfig.getId()+"HBSender", kafkaBroker, new HbJsonSerializer());
 
 		UdpPlugin udpPlugin = null; 
 		try {