从源码理解 Kafka 的分区选择策略[新的生产者发送消息分区选择]

Kafka 中将 Topic 分为 partition，消费者从 partition 中消费消息。消息是怎么确定发住哪个 partition 呢？其实默认有两种分区选择策略： 消息 key 为空时随机选择 消息 key 不为空时，对 key 进行 HASH，然后对分区数取模 源码分析 在 KafkaProducer 的 doSend 方法中调用了以下方法进行分区选择，如果指定了分区，则直接使用指定

>>阅读原文<<