kafka-自定義分區器（partitioner）_06

上一篇文章講了kafka的默認的分區器（DefaultPartitioner）源碼，這裏咱們寫一個自定義分區器的小例子java 生產者代碼以下：git /** * kafka生產者 * 使用自定義的分片器發送消息 */ public class PartitionerProducer { public static final String TOPIC_NAME = "producer-

>>阅读原文<<