Kafka-生產者

文章目錄 1. 發送消息主要步驟 2. 發送消息 3. 生產者核心配置參數 4. 分區策略 5. TCP連接 1. 發送消息主要步驟 ProduceRecord對象包含了目標主題和消息內容，也可以額外指定消息鍵或者分區。調用send()方法後，序列化器首先將消息和鍵序列化成字節數組，隨後將數據傳遞給分區器。分區器的默認分區策略是：輪詢+按鍵哈希映射。確認分區之後，消息被加入到該分區的一個批次之中，

>>阅读原文<<