从另一个配置类将主题注入到@KafkaListener注释

Question

我有一个java配置类是这样的

@Configuration
public class MyConfig {
    @Value("${kafka.topic:default_topic}")
    String kafkaTopic;
}

我当前的 KafkaListener 有这样的注释

 @KafkaListener(topics = "${kafka.topic}")
    public void processMe(@Payload  String  msg) {

我想使用配置类中的 getter 方法并将主题注入 KafkaListener。 KafkaListener 在它自己的类中

这怎么可能做到？

Answer 1

您可以使用spring表达式语言

访问

@KafkaListener(topics = "#{myConfig.getKafkaTopic()}")
public void processMe(@Payload  String  msg) {