Kafka 架构

Producer

  Broker0  Controller

Pull

Replication  A-0

Consumer

  Broker1

Replication  A-1

TopicAPartition0Follower

Producer 生产者

Kafka 集群

  Broker2

TopicAPartition1Follower

TopicAPartition1Leader

Push

Replication  B-0

0.9 版本之前 offset 存储在 ZK0.9 版本及之后 offset 存储在本地2.8 版本之后 Kafka 可以脱离 ZooKeeper 独立工作

TopicAPartition：2Replication：3

Consumer Group1for TopicA

TopicAPartition0Leader

Consumer Group2for TopicB

TopicBPartition0Follower

Consumer 消费者

TopicBPartition0Leader

TopicBPartition：1Replication：3