Quarkus使用${quarkus.uuid}配置Kafka随机group.id报错如何解决

方案1：修改配置表达式（优先尝试） #

你遇到的报错是因为quarkus.uuid的初始化时机晚于smallrye messaging配置的加载时机，导致表达式解析时无法找到对应配置值。可直接替换为SmallRye Config原生内置的随机UUID表达式即可，无需额外代码：
在application.properties中修改配置为：

mp.messaging.incoming.incoming_topic_name.group.id=${random.uuid}

${random.uuid}是SmallRye配置组件原生支持的动态生成表达式，加载优先级更高，不会出现解析失败的问题，每次应用启动都会生成全新的随机UUID作为group.id。

方案2：编程式自定义消费者配置（更稳定可控） #

如果配置表达式的方式不符合你的使用场景，可通过Quarkus提供的消费者配置定制器扩展点动态设置随机group.id：

1. 先删除application.properties中对应通道的group.id配置项
2. 新增如下CDI Bean即可：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import io.quarkus.kafka.client.consumer.ConsumerConfigCustomizer;
import javax.enterprise.context.ApplicationScoped;
import java.util.Map;
import java.util.UUID;

@ApplicationScoped
public class RandomGroupIdCustomizer implements ConsumerConfigCustomizer {
    @Override
    public void customize(String channel, Map<String, Object> config) {
        // 仅针对指定通道设置随机group.id，移除if判断可实现所有消费者通道都使用随机group.id
        if ("incoming_topic_name".equals(channel)) {
            config.put(ConsumerConfig.GROUP_ID_CONFIG, UUID.randomUUID().toString());
        }
    }
}

注意事项 #

使用随机group.id时，Kafka会将每次重启后的消费者识别为全新的消费组，需提前确认auto.offset.reset配置符合你的业务消费逻辑，避免出现消息漏消费或者重复消费的问题。

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