#586 suffix kafka consumer/producer client ids

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
eclipse-ditto · Jun 9, 2021 · 56eef15 · 56eef15
1 parent b3a8156
commit 56eef15
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...c/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java b/...c/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/PropertiesFactory.java
@@ -72,7 +72,7 @@ ConsumerSettings<String, String> getConsumerSettings() {
         return ConsumerSettings.apply(config.getConsumerConfig(), new StringDeserializer(), new StringDeserializer())
                 .withBootstrapServers(bootstrapServers)
                 .withGroupId(connection.getId().toString())
-                .withClientId(clientId);
+                .withClientId(clientId + "-consumer");
     }
 
     ProducerSettings<String, String> getProducerSettings() {
@@ -84,7 +84,7 @@ ProducerSettings<String, String> getProducerSettings() {
     }
 
     private Map<String, String> getClientIdProperties() {
-        return Map.of(CommonClientConfigs.CLIENT_ID_CONFIG, clientId);
+        return Map.of(CommonClientConfigs.CLIENT_ID_CONFIG, clientId + "-producer");
     }
 
     private Map<String, String> getSpecificConfigProperties() {