Kafka主题分区0未被使用

Question

我创建了一个包含3个分区的主题

Topic:fixtures  PartitionCount:3    ReplicationFactor:1 Configs:
    Topic: fixtures Partition: 0    Leader: 0   Replicas: 0 Isr: 0
    Topic: fixtures Partition: 1    Leader: 0   Replicas: 0 Isr: 0
    Topic: fixtures Partition: 2    Leader: 0   Replicas: 0 Isr: 0

我使用Java制作人同步写入主题

producer.send(new ProducerRecord<>(KafkaProperties.TOPIC_FIXTURES, key, value)).get();

我有一个Java的用户订阅并阅读它

Consumer<String, String> kafkaConsumer = new KafkaConsumer<>(configs);
kafkaConsumer.subscribe(Collections.singletonList(KafkaProperties.TOPIC_FIXTURES));

我的键总是一组固定的3个不同的字符串（k1、k2、k3）。但是我的消息总是去分区1或分区2——k1和k2去分区1，k3去分区2。

为什么分区0未使用？

Answer 1

对于键控消息，默认分区程序根据键的哈希值计算分区。

对于许多密钥，使用密钥哈希是在分区之间均匀分布消息的有效方法。

但是如果您只有很少几个不同的键（或者如果键的数量接近分区的数量），则可能不会使用所有分区。

如果是这种情况，那么您可以使用partitioner.class配置将自己的分区程序提供给生产者，例如进行循环。