kafka隨機寫數據到不同分區

一、定義Partitions類。  二、Producer 數據 public class Producer implements Runnable {       private final KafkaProducer<String, String> producer;     private final String topic;     public Producer(String topic
相關文章
相關標籤/搜索