使用RoundRobinPartitioner时Kafka生产者仅分配偶数分区问题排查

云原生阿岚

2026-7-27

解决方案

1. 修正ProducerFactory注入错误

你的代码中，kafkaTemplate() Bean调用的是producerFactory()，但配置了RoundRobinPartitioner的ProducerFactory Bean是dtoProducerFactory()，这会导致KafkaTemplate使用未配置自定义分区器的默认ProducerFactory，从而出现分区分配异常。

修改KafkaTemplate的Bean定义：

@Bean
public KafkaTemplate<String, Dto> kafkaTemplate() {
    return new KafkaTemplate<>(dtoProducerFactory()); // 替换为配置了分区器的ProducerFactory
}

2. 强制刷新主题元数据

如果主题是在生产者启动后才扩容到6个分区，生产者可能未及时获取最新的分区元数据，导致仅轮询旧的3个分区。

在生产者配置中添加元数据刷新间隔参数，缩短更新周期：

props.put(ProducerConfig.METADATA_MAX_AGE_MS_CONFIG, 30000); // 设置为30秒，默认5分钟

重启生产者实例，强制加载最新的主题分区信息。

3. 确认主题分区状态

先通过Kafka命令行工具验证主题的分区数量和状态：

kafka-topics.sh --describe --topic 你的主题名称 --bootstrap-server 你的Broker地址:9092

确保输出中显示6个分区，且所有分区的Leader状态为online，副本配置正常。

4. 验证分区器配置是否生效

在发送消息时，打印实际发送的分区号，确认分区器逻辑是否正常执行：

ListenableFuture<SendResult<String, Dto>> future = kafkaTemplate.send("你的主题名称", dto);
future.addCallback(result -> {
    System.out.println("消息发送至分区：" + result.getRecordMetadata().partition());
}, ex -> {
    ex.printStackTrace();
});

如果打印的分区号仍仅包含偶数，说明分区器配置未被正确加载，需要检查配置是否被其他逻辑覆盖。