From a6ac6e3221ec63afe380bdde71530a148de39c36 Mon Sep 17 00:00:00 2001
From: Christian Tzolov <christian.tzolov@gmail.com>
Date: Thu, 6 Aug 2020 20:13:51 +0200
Subject: [PATCH] Fix mime type all support for KafkaNullConverter

---
 .../cloud/stream/binder/kafka/KafkaNullConverter.java        | 5 +++++
 1 file changed, 5 insertions(+)

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