From 2acfd34e43027ef43a0b58d1d5035c577d12eec7 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Fri, 28 Aug 2020 16:27:55 +0200 Subject: [PATCH] Add supportsMimeType to KafkaNullConverter --- .../cloud/stream/config/BinderFactoryAutoConfiguration.java | 5 +++++ 1 file changed, 5 insertions(+) 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");