move initialisation of logger back to top

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
eclipse-ditto · May 18, 2021 · 0e36e35 · 0e36e35
1 parent 5a7ac98
commit 0e36e35
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java b/.../main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java
@@ -56,6 +56,8 @@ private KafkaConsumerActor(final Connection connection,
             final Source source, final boolean dryRun) {
         super(connection, sourceAddress, inboundMappingProcessor, source);
 
+        log = DittoLoggerFactory.getThreadSafeDittoLoggingAdapter(this);
+
         final Enforcement enforcement = source.getEnforcement().orElse(null);
         final EnforcementFilterFactory<Map<String, String>, Signal<?>> headerEnforcementFilterFactory =
                 enforcement != null
@@ -65,7 +67,6 @@ private KafkaConsumerActor(final Connection connection,
                 () -> new KafkaMessageTransformer(source, sourceAddress, headerEnforcementFilterFactory,
                         inboundMonitor);
         kafkaStream = new KafkaConsumerStream(factory, kafkaMessageTransformerFactory, dryRun);
-        log = DittoLoggerFactory.getThreadSafeDittoLoggingAdapter(this);
     }
 
     private static boolean isExternalMessage(final String key, final Object value) {