Other callback.....
callback下游puher保证
broker
Pusher consumer 2
Broker 1Topic APartition 1Replication 1
Broker 2Topic BPartition 1Replication 2
Redian callback(Http)
Message Queue
Baike callback(Http)
Broker 2Topic APartition 1Replication 2
Broker 3Topic APartition 2Replication 1
Redian
Broker 4Topic APartition 2Replication 2
Producer
Broker 3Topic BPartition 2Replication 1
Pusher获取消息推送下游Pusher本身无状态
BBS callback(Http)
ProducerN....
和ZK交互获取leader后与broker交互
Pusher consumer 1
MqProxy(Http)
Interface
zookeeper
Broker有状态多分片多副本zk保存leader
Pusher consumer 3
BBS
pusher(callback)
mqproxy对外提供一致性消息提交接口业务方提供Topic、Partition等
Broker 4Topic BPartition 2Replication 2
Producer1
Broker 1Topic BPartition 1Replication 1
consumer
producer无状态
Baike
Other consumer
Producer2
Producer3
