1、数据可靠性保证，数据同步 　　为保证 producer 发送的数据，能可靠的发送到指定的 topic，topic 的每个 partition 收到 producer 发送的数据后，都 ...

watcher概念 https://zookeeper.apache.org/doc/r3.4.14/zookeeperProgrammers.html#sc_WatchRememberThese ...

1、消费方式 　　consumer 采用 pull（拉） 模式从 broker 中读取数据。　　push（推）模式很难适应消费速率不同的消费者，因为消息发送速率是由 broker 决定的。　　 ...

控制器组件（Controller），是 Apache Kafka 的核心组件。它的主要作用是在 Apache ZooKeeper 的帮助下管理和协调整个 Kafka 集群。集群中任意一台 Broker ...