kafka producer工作流程

      ①、首先要構造一個 ProducerRecord 對象,該對象可以聲明主題Topic、分區Partition、鍵 Key以及值 Value,主題和值是必須要聲明的,分區和鍵可以不用指定。   ②、調用send() 方法進行消息發送。   ③、因爲消息要到網絡上進行傳輸,所以必須進行序列化,序列化器的作用就是把消息的 key 和 value對象序列化成字節數組。   ④、接下來數據傳到分
相關文章
相關標籤/搜索