diff --git a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java
index 940bc47de9..4e9d8417af 100644
--- a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java
+++ b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java
@@ -80,11 +80,10 @@ public Either<ExternalMessage, DittoRuntimeException> transform(
                 .getOrDefault(DittoHeaderDefinition.CORRELATION_ID.getKey(), UUID.randomUUID().toString());
         try {
             final DittoLogger correlationIdScopedLogger = LOGGER.withCorrelationId(correlationId);
-            if (correlationIdScopedLogger.isDebugEnabled()) {
-                correlationIdScopedLogger.debug(
-                        "Transforming incoming kafka message <{}> with headers <{}> for thing with ID <{}>.",
-                        value, messageHeaders, key);
-            }
+            correlationIdScopedLogger.debug(
+                    "Transforming incoming kafka message <{}> with headers <{}> and key <{}>.",
+                    value, messageHeaders, key
+            );
 
             final ExternalMessage externalMessage = ExternalMessageFactory.newExternalMessageBuilder(messageHeaders)
                     .withTextAndBytes(value, value == null ? null : value.getBytes())