一個典型的kafka集群包含若干Producer（可以是應用節點產生的消息，也可以是通過Flume收集日志產生的事件），若干個Broker（kafka支持水平擴展）、若干個Consumer Group，以及一個zookeeper集群。kafka通過zookeeper管理集群配置及服務協同。Producer使用push模式將消息發布到broker，consumer通過監聽使用pull模式從broker訂閱并消費消息。

多個broker協同工作，producer和consumer部署在各個業務邏輯中。三者通過zookeeper管理協調請求和轉發。這樣就組成了一個高性能的分布式消息發布和訂閱系統。

圖上有一個細節是和其他mq中間件不同的點，producer 發送消息到broker的過程是push，而consumer從broker消費消息的過程是pull，主動去拉數據。而不是broker把數據主動發送給consumer

?

總結

以上是生活随笔為你收集整理的Kafka本身的架构的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。