diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java index eb71c2f6..c52e1eff 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java @@ -72,6 +72,7 @@ import org.springframework.core.annotation.AnnotationUtils; import org.springframework.core.convert.TypeDescriptor; import org.springframework.core.convert.converter.ConditionalGenericConverter; import org.springframework.core.convert.converter.Converter; +import org.springframework.core.convert.converter.ConverterFactory; import org.springframework.core.convert.converter.GenericConverter; import org.springframework.core.log.LogAccessor; import org.springframework.format.Formatter; @@ -1021,6 +1022,9 @@ public class KafkaListenerAnnotationBeanPostProcessor for (Converter converter : getBeansOfType(Converter.class)) { registry.addConverter(converter); } + for (ConverterFactory converter : getBeansOfType(ConverterFactory.class)) { + registry.addConverterFactory(converter); + } for (GenericConverter converter : getBeansOfType(GenericConverter.class)) { registry.addConverter(converter); }