Spring Kafka KafkaListener 注释是否能够将配置属性作为主题名称？

Question

我有以下定义：

    @KafkaListener(
            topics = "${app.kafka.eventTopic}",
            groupId = "${app.kafka.consumerGroupId}",
            concurrency = "${app.kafka.concurrency}"
    )

我在我的 yaml 文件中定义了这些配置属性，例如：

app:
  kafka:
    eventTopic: topicName
    consumerGroupId: groupName
    concurrency: 10

我是 SpringBoot 的新手，我看到一些 SO 帖子声称 ${app.kafka.eventTopic} 之类的语法不能像 @Value() 注释那样工作，需要 ConfigurationProperties 类将属性值“翻译”为 Java变量。如果 @Value 注释是这样，那么这里对 KafkaListener 注释内容的工作方式是否相同？

Answer 1

这应该可以在没有任何“翻译器”的普通 Spring Boot 应用程序中工作。例如。只要相应的属性在您的application.properties 或application.yaml 中，这应该可以正常工作：

@KafkaListener(
    topics = "${kafka.topics.consume.somedata}", 
    id = MyConsumer.CONTAINER_ID)

您甚至可以使用更高级的 SPeL 表达式，例如：

@KafkaListener(topics = "#{'${consumer.topics}'.split(',')}", ...)

您可以阅读有关 SpEL 的更多信息here。

实际上，Value 和 KafkaListener 注释的处理方式略有不同。一个来自AutowiredAnnotationBeanPostProcessor，另一个来自KafkaListenerAnnotationBeanPostProcessor。