diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java index cfac8e974..3175348ad 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java @@ -256,6 +256,11 @@ public class BinderFactoryAutoConfiguration { return "org.springframework.kafka.support.KafkaNull".equals(aClass.getName()); } + @Override + protected boolean supportsMimeType(@Nullable MessageHeaders headers) { + return true; + } + @Override protected boolean canConvertFrom(Message message, Class targetClass) { return message.getPayload().getClass().getName().equals("org.springframework.kafka.support.KafkaNull");