apache-kafka - Kafka 分区中消息分布不均

Question

我有一个有 10 个分区的主题，1 个有 4 个消费者的消费者组，工作人员的大小是 3。

我可以看到分区中的消息分布不均匀，一个分区有这么多数据，另一个是免费的。

如何让我的生产者将负载均匀地分配到所有分区中，以便正确利用所有分区？

Answer 1

您可以为生产者分配一个分区号，而不是使用默认的分区程序类，以便消息直接发送到指定的分区，

 ProducerRecord<String, String> record = new ProducerRecord<String, String>(topicName, partitionNumber,key, value);