kafka(三): 數據生產流程,數據複製與Replica Failover

【這是一篇7月份躺在草稿箱的文章,今天翻出來整理一下。】 數據生產流程 1.發送到kafka的數據會封裝爲ProducerRecord對象,包含topic、partition、key、value信息; 2.調用send()方法後,將數據序列化爲字節數組,如果沒有指定分區 ,那麼分區器會根據ProducerRecord 對象的鍵來計算一個分區; 3.當消息達到一個批次設定的量(消息放在緩衝區中),通
相關文章
相關標籤/搜索