Quarkus SmallRye Reactive Messaging：Kafka主题统一前缀配置问询

完全可以实现统一给所有Kafka主题（包括手动指定的主题、延迟重试主题、死信队列主题）添加前缀或后缀，下面是基于Quarkus（适配MicroProfile Reactive Messaging）的具体实现方法：

1. 自定义主题名称生成器 #

实现Quarkus提供的KafkaTopicNameGenerator接口，在这个类里统一处理主题名的前缀/后缀逻辑，从配置中读取环境标识，避免硬编码。

import io.quarkus.kafka.client.serialization.KafkaTopicNameGenerator;
import jakarta.enterprise.context.ApplicationScoped;
import org.eclipse.microprofile.config.inject.ConfigProperty;

@ApplicationScoped
public class EnvironmentPrefixedTopicGenerator implements KafkaTopicNameGenerator {

    // 从配置文件读取前缀，默认空字符串（生产环境可留空）
    @ConfigProperty(name = "kafka.topic.prefix", defaultValue = "")
    String topicPrefix;

    @Override
    public String generate(String channelName, String defaultTopic) {
        // 对所有传入的主题名添加前缀，包括手动指定的、重试、死信队列主题
        return topicPrefix + defaultTopic;
    }
}

如果需要添加后缀，只需修改返回逻辑（建议把配置名改为kafka.topic.suffix更清晰）：

return defaultTopic + topicSuffix;

2. 配置环境标识 #

在application.yaml中添加前缀/后缀的配置，不同环境可以通过配置文件或环境变量覆盖：

# 环境前缀，比如QA环境用qa-，预发布用preprod-
kafka.topic.prefix=qa-

# 原有的消息通道配置无需修改
mp.messaging.outgoing.some-topic-out.topic=some-topic
mp.messaging.incoming.some-topic.delayed-retry-topic.topics=some-topic-retry_100,some-topic-retry_1000,some-topic-retry_15000,some-topic-retry_60000,some-topic-retry_600000
mp.messaging.incoming.some-topic.dead-letter-queue.topic=some-topic-dead-letter

3. 效果验证 #

配置生效后，所有主题都会自动带上前缀：

• 出站主题some-topic → qa-some-topic
• 延迟重试主题集合 → qa-some-topic-retry_100、qa-some-topic-retry_1000等
• 死信队列主题some-topic-dead-letter → qa-some-topic-dead-letter

这种方式一次配置全局生效，不需要逐个修改通道的主题配置，完美适配多环境共用Kafka Broker的场景。

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