Kafka 生产者在 org.apache.kafka.clients.producer.RoundRobinPartitioner 中的 0,2,4...等替代分区中产生价值
我有 6 个分区，它们是 6 个并发消费者，并且遵循配置 org.apache.kafka.clients.producer.RoundRobinPartitioner。在生成消息时，kafka 仅以替代方式将消息放入 3 个分区。这使得其他分区未被利用，消息在队列中等待 6 个并发调用，因为只有 3 个正在使用。我怎样才能实现平等分配。 有没有我缺少的配置。请建议。 props.put(partitioner.class, "org.apache.kafka.clients.producer.RoundRobinPartitioner");
props.put(partitioner.class, "org.apache.kafka.clients.producer.RoundRobinPartitioner");