SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add logging for deserialization failures.

Browse Source
This commit is contained in:
Arnaud
2018-12-12 09:18:26 +01:00
committed by Soby Chacko
parent 43c8f02bff
commit e93904c238
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java
View File

@@ -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;