kafka？

kafka的通訊協議是基于tcp之上的二進制協議，所有類型的請求和響應都是結構化的，由不同的初始類型構成。kafka使用這組協議完成各個功能的實現。

單個kafka client通常需要同時連接多個broker服務器進行數據交互，但每個broker之上只需要維護一個Socket連接用于數據傳輸。clients可能會創建額外的socket連接用于其他任務，如元數據獲取以及組rebalance等。kafka自帶的java clients使用了類似于epoll的方式在單個連接上不停的輪訓以傳輸數據。