KafkaListener 未使用“#{__listener.getContainerFactory()}”解析 containerFactory

Question

我正在使用以下方法来获取 KafkaListener 属性。 但它不解析 containerFactory 值。但它适用于主题和 groupId。

@KafkaListener(topics = "#{__listener.getTopics()}",
            groupId = "#{__listener.getGroupId()}",
            containerFactory =  "#{__listener.getContainerFactory()}")
    public void sampleTestTopicListener(@Payload byte[] data,

.....
 @Value("sampleTestListenerContainerFactory")
    private String containerFactory ;

    public String  getContainerFactory(){
        return containerFactory;
    }
....
Spring-kafka-2.2.5.RELEASE 

I get the following error :
A component required a bean named '#{__listener.getContainerFactory()}' that could not be found.

Changing the containerFactory value to "sampleTestListenerContainerFactory" instead of spEL, it works fine.

如何使用当前的 beans 属性设置它？

Answer 1

@KafkaListener 注释上的 containerFactory 选项不能作为 SpEL 表达式。不过，您可以使用属性占位符解析。像这样：

containerFactory = "${sampleTestListenerContainerFactory}"

但最好还是使用真正的 bean 名称：KafkaListenerContainerFactory 真的必须是 bean...

另一个注意事项：Apache Kafka 2.2.5 的 Spring 版本不支持。它在很久以前就达到了生命的尽头。保持最新版本更实用：https://spring.io/projects/spring-kafka#learn