自定義kafka分區器Partitioner

研究分區器先從ProducerRecord看起，因爲分區是在每條record的基礎上實現的。 ProducerRecord的字段： 在構造函數中可以指定partition，消息會直接放在指定的分區上。如果不指定partion，那麼就會以默認分區器，按照key的散列算法進行分區，分佈在主題的所有分區上，有可能放在不可用的分區上。相同的key會有相同的散列值，相同的散列值會在同一個分區，也就是相同ke

>>阅读原文<<