broker（代理）

kafka集群通常由多个代理组成以保持负载平衡。 kafka代理是无状态的，所以他们使用zookeeper来维护它们的集群状态。 一个kafka代理实例可以每秒处理数十万次读取和写入，每个broker可以处理tb的消息，而没有性能影响。 kafka经纪人领导选举可以由zookeeper完成。

zookeeper

zookeeper用于管理和协调kafka代理。 zookeeper服务主要用于通知生产者和消费者kafka系统中存在任何新代理或kafka系统中代理失败。 根据zookeeper接收到关于代理的存在或失败的通知，然后产品和消费者采取决定并开始与某些其他代理协调他们的任务。

producers（生产者）

生产者将数据推送给经纪人。 当新代理启动时，所有生产者搜索它并自动向该新代理发送消息。 kafka生产者不等待来自代理的确认，并且发送消息的速度与代理可以处理的一样快。

consumers（消费者）

因为kafka代理是无状态的，这意味着消费者必须通过使用分区偏移来维护已经消耗了多少消息。 如果消费者确认特定的消息偏移，则意味着消费者已经消费了所有先前的消息。 消费者向代理发出异步拉取请求，以具有准备好消耗的字节缓冲区。 消费者可以简单地通过提供偏移值来快退或跳到分区中的任何点。 消费者偏移值由zookeeper通知。