kafka-自定义分区器（partitioner）_06

上一篇文章讲了kafka的默认的分区器（DefaultPartitioner）源码，这里咱们写一个自定义分区器的小例子java 生产者代码以下：git /** * kafka生产者 * 使用自定义的分片器发送消息 */ public class PartitionerProducer { public static final String TOPIC_NAME = "producer-

>>阅读原文<<