diff --git a/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java b/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java
index e8b2e03f1..2fe5b34ea 100644
--- a/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java
+++ b/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java
@@ -197,8 +197,10 @@ 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(), 
@@ -206,7 +208,7 @@ public static void main(String[] args) {
 				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 {