Fix mime type all support for KafkaNullConverter

2020-08-06 20:13:51 +02:00
parent 6280489be8
commit a6ac6e3221
1 changed files with 5 additions and 0 deletions
--- 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);