日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

產(chǎn)品架構(gòu)

本文介紹云消息隊列 Kafka 版的系統(tǒng)架構(gòu)和發(fā)布/訂閱模型。

云消息隊列 Kafka 版系統(tǒng)架構(gòu)

云消息隊列 Kafka 版的系統(tǒng)架構(gòu)所示,一個云消息隊列 Kafka 版集群包括Producer、Kafka Broker、Group、ZooKeeper。

圖 1. 云消息隊列 Kafka 版的系統(tǒng)架構(gòu)系統(tǒng)架構(gòu)

  • Producer

    • 通過push模式向云消息隊列 Kafka 版的Kafka Broker發(fā)送消息。發(fā)送的消息可以是網(wǎng)站的頁面訪問、服務(wù)器日志,也可以是CPU和內(nèi)存相關(guān)的系統(tǒng)資源信息。

  • Kafka Broker

    • 用于存儲消息的服務(wù)器。Kafka Broker支持水平擴展。Kafka Broker節(jié)點的數(shù)量越多,云消息隊列 Kafka 版集群的吞吐率越高。

  • Group

    • 通過pull模式從云消息隊列 Kafka 版Broker訂閱并消費消息。

  • Zookeeper

    • 管理集群的配置、選舉leader分區(qū),并且在Group發(fā)生變化時,進(jìn)行負(fù)載均衡。

云消息隊列 Kafka 版的發(fā)布/訂閱模型

云消息隊列 Kafka 版的發(fā)布/訂閱模型所示,云消息隊列 Kafka 版采用發(fā)布/訂閱模型。

圖 2. 云消息隊列 Kafka 版的發(fā)布/訂閱模型發(fā)布訂閱模型

  • Group和Topic的對應(yīng)關(guān)系是N : N,即一個Group可以同時訂閱多個Topic,一個Topic也可以被多個Group同時訂閱。

  • 雖然一個Topic可以被多個Group同時訂閱,但該Topic的消息只能被同一個Group內(nèi)的任意一個Consumer消費。