diff --git a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/TransformationResult.java b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/TransformationResult.java index c81d60c4c1..9d80a09362 100644 --- a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/TransformationResult.java +++ b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/TransformationResult.java @@ -90,7 +90,8 @@ boolean isExpired() { } catch (final Exception e) { // Errors during reading/parsing headers should not cause the message to be dropped. final Object message = null != externalMessage ? externalMessage : dittoRuntimeException; - LOGGER.warn("Encountered error checking the expiry of Kafka message: <{}>, <{}>", message, e); + LOGGER.warn("Encountered error checking the expiry of Kafka message: <{}>, <{}>: {}", message, + e.getClass().getSimpleName(), e.getMessage(), e); return false; } }