Producer生产者负责将数据发布到 Kafka 中的主题Topic。消息会按照某种逻辑如轮询、键值哈希等分发到该主题的不同分区生产者可以发送单个消息或者批量消息到指定的主题。Consumer消费者从主题中的特定分区读取消息。消费者可以是单个实例也可以组成一个消费者组Consumer Group。Kafka 支持多消费者模型每个消费者组能够独立读取主题中的数据。Kafka 通过消费者组Consumer Group管理消费进度确保消息被所有需要的消费者组消费。BrokerKafka 集群中的每个节点称为一个 Broker。Broker 负责接收、存储和提供来自生产者的消息。一个 Kafka 集群通常由多个 Broker 组成每个主题的分区会分布在不同的 Broker 上分布式存储消息以实现高可用性和容错性。Topic数据在 Kafka 中是通过主题组织的。生产者将数据发送到主题中消费者从主题中读取数据。主题可以分为多个分区Partition分区使得主题能够水平扩展以提高吞吐量和并行处理能力。Partition每个主题都可以被分为多个分区分区是 Kafka 中的基本并行单元。每个分区中的消息是有序的但是跨分区的消息没有全局顺序。通过分区Kafka 能够在集群中分布负载并实现高并发的数据处理。ZookeeperKafka 使用 Zookeeper 来管理集群的元数据、Broker 状态、主题配置等信息。在新的 Kafka 版本中Zookeeper 被逐渐替代为 Kafka 自带的集群协调功能但在旧的版本中Zookeeper 是必需的。Leader 和 Follower每个分区都有一个 Leader 和若干 Follower。Leader 负责处理生产者和消费者的读写请求而 Follower 只负责同步 Leader 中的数据。当 Leader 失效时Kafka 通过 Zookeeper 或自带的协调功能选举新的 Leader。