Kafka-生產者

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