diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java index 1b7d6f807..713dbf338 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java @@ -38,6 +38,11 @@ public class KafkaNullConverter extends AbstractMessageConverter { super(Collections.singletonList(MimeTypeUtils.ALL)); } + @Override + protected boolean supportsMimeType(MessageHeaders headers) { + return true; + } + @Override protected boolean supports(Class aClass) { return KafkaNull.class.equals(aClass);