Renames the client.id used by the kafka producers @see #110

IntegratedAlarmSystem-Group · Jun 18, 2018 · 457c9f9 · 457c9f9
1 parent 5c3542f
commit 457c9f9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/Converter/src/java/org/eso/ias/converter/ConverterConfig.java b/Converter/src/java/org/eso/ias/converter/ConverterConfig.java
@@ -58,7 +58,7 @@ public ConverterStream converterStream(String cID, Optional<String> kafkaBrokers
 	@Lazy(value = true)
 	public HbProducer hbProducer(String cID, Optional<String> kafkaBrokers, Properties props) { 
 		return new HbKafkaProducer(
-				cID, getKafkaServer(kafkaBrokers, props),
+				cID+"HBSender", getKafkaServer(kafkaBrokers, props),
 				new HbJsonSerializer()); 
 	}
 }
diff --git a/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java b/PythonPluginFeeder/src/java/org/eso/ias/plugin/network/UdpPlugin.java
@@ -206,7 +206,7 @@ public static void main(String[] args) {
 				pluginConfig.getSinkPort(), 
 				Plugin.getScheduledExecutorService());
 
-		HbProducer hbProducer = new HbKafkaProducer(pluginConfig.getId(), new HbJsonSerializer());
+		HbProducer hbProducer = new HbKafkaProducer(pluginConfig.getId()+"HBSender", new HbJsonSerializer());
 
 		UdpPlugin udpPlugin = null; 
 		try {

diff --git a/Supervisor/src/scala/org/eso/ias/supervisor/Supervisor.scala b/Supervisor/src/scala/org/eso/ias/supervisor/Supervisor.scala
@@ -397,7 +397,7 @@ object Supervisor {
     val hbProducer: HbProducer = {
       val kafkaServers = System.getProperties.getProperty(KafkaHelper.BROKERS_PROPNAME,KafkaHelper.DEFAULT_BOOTSTRAP_BROKERS)
 
-      new HbKafkaProducer(supervisorId,kafkaServers,new HbJsonSerializer())
+      new HbKafkaProducer(supervisorId+"HBSender",kafkaServers,new HbJsonSerializer())
     }
 
     // Build the supervisor