从源码理解 Kafka 的分区选择策略

从源码理解 Kafka 的分区选择策略

Kafka 中将 Topic 分为 partition,消费者从 partition 中消费消息。消息是怎么确定发住哪个 partition 呢?其实默认有两种分区选择策略:

  1. 消息 key 为空时随机选择
  2. 消息 key 不为空时,对 key 进行 HASH,然后对分区数取模
阅读更多