本文介紹云消息隊列 Kafka 版的系統架構和發布/訂閱模型。
云消息隊列 Kafka 版系統架構
如云消息隊列 Kafka 版的系統架構所示，一個云消息隊列 Kafka 版集群包括Producer、Kafka Broker、Group、ZooKeeper。
圖 1. 云消息隊列 Kafka 版的系統架構
Producer
通過push模式向云消息隊列 Kafka 版的Kafka Broker發送消息。發送的消息可以是網站的頁面訪問、服務器日志，也可以是CPU和內存相關的系統資源信息。
Kafka Broker
用于存儲消息的服務器。Kafka Broker支持水平擴展。Kafka Broker節點的數量越多，云消息隊列 Kafka 版集群的吞吐率越高。
Group
通過pull模式從云消息隊列 Kafka 版Broker訂閱并消費消息。
Zookeeper
管理集群的配置、選舉leader分區，并且在Group發生變化時，進行負載均衡。
云消息隊列 Kafka 版的發布/訂閱模型
如云消息隊列 Kafka 版的發布/訂閱模型所示，云消息隊列 Kafka 版采用發布/訂閱模型。
圖 2. 云消息隊列 Kafka 版的發布/訂閱模型
Group和Topic的對應關系是N : N，即一個Group可以同時訂閱多個Topic，一個Topic也可以被多個Group同時訂閱。
雖然一個Topic可以被多個Group同時訂閱，但該Topic的消息只能被同一個Group內的任意一個Consumer消費。
文檔內容是否對您有幫助？