Add supportsMimeType to KafkaNullConverter

This commit is contained in:
Oleg Zhurakousky
2020-08-28 16:27:55 +02:00
parent 7d76a109a8
commit 2acfd34e43

View File

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