Quarkus中能否通过配置文件为@Incoming注解指定Kafka Topic名称？

Quarkus完全支持通过配置文件动态指定@Incoming注解的参数值，实现方式和你熟悉的Spring模式一致，具体步骤如下：

• 1. 在配置文件中定义Topic名称
  以application.yml为例：

  topic:
    name: my-kafka-topic
  

  若使用application.properties：

  topic.name=my-kafka-topic
  

• 2. 在@Incoming注解中引用配置值
  直接通过${配置键}的语法将配置文件中的值注入到注解参数中：

  @ApplicationScoped
  public class Consumer {
      
      @Incoming("${topic.name}")
      public void consume(String s) {
          Log.info(s);
      }
  }
  

• 3. 可选：配置默认值
  如果想在配置未定义时使用默认Topic名称，可以添加默认值表达式：

  @Incoming("${topic.name:default-topic}")
  

这种方式适用于Quarkus的大部分注解参数动态化场景，Kafka消费者的场景完全适配。

内容的提问来源于stack exchange，提问作者Andrew Samoilov