diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java index 6b0e5f641..302e555ba 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java @@ -140,7 +140,8 @@ public class KafkaStreamsMessageConversionDelegate { LOG.info("Received a tombstone record. This will be skipped from further processing."); } } - catch (Exception ignored) { + catch (Exception e) { + LOG.warn("Deserialization has failed. This will be skipped from further processing.", e); //pass through } return isValidRecord;