kafka6 編寫使用自定義分區的生產者

一 客戶端 在上一篇博客創建的簡單生產者的基礎上，進行兩個修改操作： 1.新建SimplePartitioner.java，修改返回分區爲1。 SimplePartitioner.java代碼如下 package cn.test.mykafka; import java.util.Map; import org.apache.kafka.clients.producer.Partitioner

>>阅读原文<<