kafka6 编写使用自定义分区的生产者

一 客户端 在上一篇博客创建的简单生产者的基础上，进行两个修改操作： 1.新建SimplePartitioner.java，修改返回分区为1。 SimplePartitioner.java代码如下 package cn.test.mykafka; import java.util.Map; import org.apache.kafka.clients.producer.Partitioner

>>阅读原文<<