Spring Kafka自动为clientId添加-n后缀，如何移除该后缀？

我对Spring Kafka了解有限，目前碰到一个问题：日志里能看到Spring会自动给client id加上-1（或-0）后缀，但我的Kafka基础设施要求必须用无后缀的名称，这导致了兼容性问题。

我的Listener代码 #

@Service
@Slf4j
@AllArgsConstructor
@ConditionalOnProperty(value = "kafka.event.enable")
public class KafkaEventListener {
    private final KafkaEventHandler kafkaEventHandler;

    @KafkaListener(
            topics = "gc.fds.event.external.all",
            groupId = "dispute-service-app",
            clientIdPrefix = "${kafka.groupId}",
            containerFactory = "kafkaChargebackcontainerFactory")
    public void listener(List<ChargebackKafkaEvent> kafkaEventList) {
        log.info("Received {} kafka events", kafkaEventList.size());
        kafkaEventList.forEach(kafkaEventHandler::processKafkaEvent);
    }
}

我的KafkaConfig代码 #

@Slf4j
@EnableKafka
@Configuration
public class KafkaConfig {
    @Bean
    ConcurrentKafkaListenerContainerFactory<String, List<ChargebackKafkaEvent>> kafkaChargebackcontainerFactory(KafkaProperties kafkaProperties) {
        log.info("Creating_KafkaListenerContainerFactory");
        var factory = new ConcurrentKafkaListenerContainerFactory<String, List<ChargebackKafkaEvent>>();
        factory.setConcurrency(1);
        factory.setContainerCustomizer(container -> container.setAlwaysClientIdSuffix(false));
        factory.setConsumerFactory(consumerFactory(kafkaProperties));

        return factory;
    }

    @Bean
    public ConsumerFactory<String, List<ChargebackKafkaEvent>> consumerFactory(KafkaProperties kafkaProperties) {
        Map<String, Object> consumerProperties = kafkaProperties.buildConsumerProperties();
        consumerProperties.put("client.id", "dispute-service-app");
        consumerProperties.put("group.id", "dispute-service-app");
        log.info("Kafka_consumer_properties: {}", consumerProperties);
        DefaultKafkaConsumerFactory<String, List<ChargebackKafkaEvent>> defaultKafkaConsumerFactory =
            new DefaultKafkaConsumerFactory<>(
                consumerProperties,
                new StringDeserializer(),
                new ErrorHandlingDeserializer<>(new JsonDeserializer<>(List.class, false)));

        return defaultKafkaConsumerFactory;
    }
}

日志截图 #

解决办法 #

1. 确认核心配置生效 #

你已经在容器工厂中添加了关闭后缀的关键配置：

factory.setContainerCustomizer(container -> container.setAlwaysClientIdSuffix(false));

这个配置会禁止Spring Kafka自动给client id添加数字后缀，只要你的Spring Kafka版本在2.3及以上（该方法从2.3版本开始支持），这个配置就能直接生效。

2. 调整client ID配置优先级 #

@KafkaListener中的clientIdPrefix会和consumerProperties里设置的client.id产生优先级冲突。建议移除clientIdPrefix配置，直接通过consumerProperties指定固定的client.id，避免Spring自动拼接前缀和后缀。

修改后的@KafkaListener可简化为：

@KafkaListener(
        topics = "gc.fds.event.external.all",
        groupId = "dispute-service-app",
        containerFactory = "kafkaChargebackcontainerFactory")

3. 验证并发数设置 #

你的并发数已经设为1（factory.setConcurrency(1)），即使不关闭后缀，也只会生成dispute-service-app-0，但关闭后缀后就会完全使用你指定的无后缀名称。

4. 版本兼容性检查 #

如果上述配置不生效，检查你的Spring Kafka版本是否低于2.3，若版本过低需要升级依赖以支持setAlwaysClientIdSuffix方法。

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