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

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