Quarkus中如何通过配置属性为Kafka主题添加环境前缀

针对你遇到的@Incoming无法直接拼接环境前缀的问题，这里提供两种可行的解决思路：

方法一：通过配置文件映射完整主题名 #

这是SmallRye Reactive Messaging推荐的标准做法，把主题定义完全交给配置文件处理，完美规避注解参数必须为常量的限制：

1. 在application.properties（或对应环境的配置文件）中定义消费者的主题配置，利用配置变量自动拼接前缀：

# 定义当前环境前缀
envPrefix=local
# 为指定消费者绑定带前缀的完整主题名
mp.messaging.incoming.foo_consumer.topic=${envPrefix}_foo_bar

2. 代码中@Incoming直接引用消费者的配置标识（而非硬编码主题名）：

import io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
import jakarta.enterprise.context.ApplicationScoped;
import org.eclipse.microprofile.reactive.messaging.Incoming;

@ApplicationScoped
public class FooConsumer {

    @Incoming("foo_consumer")
    public CompletionStage<Void> consume(IncomingKafkaRecord<String, String> record) {
        // 消息处理逻辑
        System.out.println("Received message: " + record.getPayload());
        return CompletableFuture.completedFuture(null);
    }
}

方法二：使用主题表达式（适用于动态主题场景） #

如果需要在代码外灵活调整主题规则，可使用SmallRye Kafka的主题表达式功能：

1. 配置文件中通过topic-expression指定带变量的主题规则：

mp.messaging.incoming.foo_consumer.topic-expression=${envPrefix}_foo_bar

2. 代码中依然通过消费者标识绑定@Incoming：

@Incoming("foo_consumer")
public CompletionStage<Void> consume(String payload) {
    // 消息处理逻辑
    return CompletableFuture.completedFuture(null);
}

你的原有方案失败原因 #

• 用ConfigProvider拼接静态常量：静态常量在类加载阶段初始化，此时Quarkus配置上下文还未完全加载，无法获取到正确的环境前缀；同时注解参数要求必须是编译期常量，运行时拼接的字符串不符合语法要求。
• 直接在@Incoming中写"${envPrefix}foo_bar"：@Incoming仅识别配置中映射的消费者标识，不支持直接解析占位符字符串。

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