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 8bca6ea4f..1b7d6f807 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
@@ -23,6 +23,7 @@ import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageHeaders;
 import org.springframework.messaging.converter.AbstractMessageConverter;
 import org.springframework.messaging.converter.MessageConverter;
+import org.springframework.util.MimeTypeUtils;
 
 /**
  * A {@link MessageConverter} that supports {@link KafkaNull} payloads.
@@ -34,7 +35,7 @@ import org.springframework.messaging.converter.MessageConverter;
 public class KafkaNullConverter extends AbstractMessageConverter {
 
 	public KafkaNullConverter() {
-		super(Collections.emptyList());
+		super(Collections.singletonList(MimeTypeUtils.ALL));
 	}
 
 	@Override