自定义kafka分区器Partitioner

研究分区器先从ProducerRecord看起，因为分区是在每条record的基础上实现的。 ProducerRecord的字段： 在构造函数中可以指定partition，消息会直接放在指定的分区上。如果不指定partion，那么就会以默认分区器，按照key的散列算法进行分区，分布在主题的所有分区上，有可能放在不可用的分区上。相同的key会有相同的散列值，相同的散列值会在同一个分区，也就是相同ke

>>阅读原文<<