kafka入門之broker--通信協議

kafka的通訊協議是基於tcp之上的二進制協議，所有類型的請求和響應都是結構化的，由不同的初始類型構成。kafka使用這組協議完成各個功能的實現。 單個kafka client通常需要同時連接多個broker服務器進行數據交互，但每個broker之上只需要維護一個Socket連接用於數據傳輸。clients可能會創建額外的socket連接用於其他任務，如元數據獲取以及組rebalance等。ka

>>阅读原文<<