diff --git a/integration-tests/cucumber-tests-platform-distributionautomation/src/test/java/org/opensmartgridplatform/cucumber/platform/distributionautomation/config/StringMessageConsumerConfig.java b/integration-tests/cucumber-tests-platform-distributionautomation/src/test/java/org/opensmartgridplatform/cucumber/platform/distributionautomation/config/StringMessageConsumerConfig.java
index 4940b782c06..a81e7c18a08 100644
--- a/integration-tests/cucumber-tests-platform-distributionautomation/src/test/java/org/opensmartgridplatform/cucumber/platform/distributionautomation/config/StringMessageConsumerConfig.java
+++ b/integration-tests/cucumber-tests-platform-distributionautomation/src/test/java/org/opensmartgridplatform/cucumber/platform/distributionautomation/config/StringMessageConsumerConfig.java
@@ -25,11 +25,10 @@ public StringMessageConsumerConfig(
       final Environment environment,
       @Value("${distributionautomation.kafka.common.properties.prefix}")
           final String propertiesPrefix,
-      @Value("${distributionautomation.kafka.topic.message}") final String topic,
       @Value("${distributionautomation.kafka.consumer.concurrency}") final int concurrency,
       @Value("${distributionautomation.kafka.consumer.poll.timeout}") final int pollTimeout) {
 
-    super(environment, propertiesPrefix, topic, concurrency, pollTimeout);
+    super(environment, propertiesPrefix, concurrency, pollTimeout);
   }
 
   @Bean("distributionAutomationMessageConsumerFactory")
diff --git a/osgp/platform/osgp-adapter-kafka-logging/src/main/java/org/opensmartgridplatform/adapter/kafka/logging/config/StringMessageConsumerConfig.java b/osgp/platform/osgp-adapter-kafka-logging/src/main/java/org/opensmartgridplatform/adapter/kafka/logging/config/StringMessageConsumerConfig.java
index 92be5342a6d..ce01f0ef5e9 100644
--- a/osgp/platform/osgp-adapter-kafka-logging/src/main/java/org/opensmartgridplatform/adapter/kafka/logging/config/StringMessageConsumerConfig.java
+++ b/osgp/platform/osgp-adapter-kafka-logging/src/main/java/org/opensmartgridplatform/adapter/kafka/logging/config/StringMessageConsumerConfig.java
@@ -25,11 +25,10 @@ public StringMessageConsumerConfig(
       final Environment environment,
       @Value("${distributionautomation.kafka.common.properties.prefix}")
           final String propertiesPrefix,
-      @Value("${distributionautomation.kafka.topic.message}") final String topic,
       @Value("${distributionautomation.kafka.consumer.concurrency}") final int concurrency,
       @Value("${distributionautomation.kafka.consumer.poll.timeout}") final int pollTimeout) {
 
-    super(environment, propertiesPrefix, topic, concurrency, pollTimeout);
+    super(environment, propertiesPrefix, concurrency, pollTimeout);
   }
 
   @Bean("distributionAutomationMessageConsumerFactory")
diff --git a/osgp/shared/shared/src/main/java/org/opensmartgridplatform/shared/application/config/kafka/AbstractKafkaConsumerConfig.java b/osgp/shared/shared/src/main/java/org/opensmartgridplatform/shared/application/config/kafka/AbstractKafkaConsumerConfig.java
index 47a6ff5bcbf..7971496e899 100644
--- a/osgp/shared/shared/src/main/java/org/opensmartgridplatform/shared/application/config/kafka/AbstractKafkaConsumerConfig.java
+++ b/osgp/shared/shared/src/main/java/org/opensmartgridplatform/shared/application/config/kafka/AbstractKafkaConsumerConfig.java
@@ -27,14 +27,13 @@ public abstract class AbstractKafkaConsumerConfig<K, V> extends KafkaConfig {
   protected AbstractKafkaConsumerConfig(
       final Environment environment,
       final String propertiesPrefix,
-      final String topic,
       final int concurrency,
       final int pollTimeout) {
     super(environment);
 
     LOGGER.debug(
         "=================================================================================");
-    LOGGER.info("Initializing Kafka Consumer for Topic {}", topic);
+    LOGGER.info("Initializing Kafka Consumer");
     LOGGER.debug("Common properties prefix: {}", propertiesPrefix);
     LOGGER.debug("Consumer properties prefix: {}", getConsumerPropertiesPrefix(propertiesPrefix));
     LOGGER.debug(