Kafka生產者一-向Kafka寫 入資料

不管是把Kafka作為訊息佇列、訊息匯流排還是資料儲存平臺來使用，總是需要有一個可以往Kafka寫人資料的生產者和一個可以從Kafka讀取資料的消費者，或者一個兼具兩種角色的應用程式。

這一章會帶著大家學習如下內容：

我們以一個生產者示例開始了本章的內容一使 用10行程式碼將訊息傳送到Kafka。然後我們在程式碼中加入錯誤處理邏輯，並介紹了同步和非同步兩種傳送方式。接下來，我們介紹了生產者的一些重要配置引數以及它們對生產者行為的影響。我們還討論了用於控制訊息格式的序列化器，並深入探討了Avro種 在Kafka中得到廣泛應用的序列化方式。最後，我們討論了Kafka的分割槽機制，並給出了一一個自定義分割槽的例子。

現在我們已經知道如何向Kafka寫入訊息，在第4章，我們將學習如何從Kafka讀取訊息。

第4章Kafka 消費者一從 Kafka讀取資料

• 消費者和消費者群組
• 消費者群組和分割槽再均衡
• 輪詢
• 消費者的配置
• 提交和偏移量.
• 提交當前偏移量
• 同步和非同步組合提交
• 提交特定的偏移量
• 從特定偏移量處開始處理記錄
• 獨立消費者一為什 麼以及怎樣使用沒有群組的消費者.

第6章可靠的資料傳遞

• 可靠性保證
• 複製
• broker配置
• 在可靠的系統裡使用生產者
• 在可靠的系統裡使用消費者
• 驗證系統可靠性

頭條篇幅有限，無法全部介紹！

有需要這份Kafka學習文件的可以後臺私信我獲取連結！

轉發此文關注作者然後看下圖中免費獲取方式