From 168b9d274f9d511d5af6d81048c2ca44e15a2344 Mon Sep 17 00:00:00 2001 From: wruiiwang <1434053049@qq.com> Date: Tue, 7 Jun 2022 22:49:03 +0800 Subject: [PATCH] Add Converter Factories to Method Factory Similar to `Converter`s, add any `ConverterFactory` beans to the default `MessageHandlerMethodFactory`. add converterFactory add converterFactory add converterFactory --- .../annotation/KafkaListenerAnnotationBeanPostProcessor.java | 4 ++++ 1 file changed, 4 insertions(+) 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); }