应用程序向 Kafka 发送消息的客户端。
根据 key 决定写入哪个 Partition,默认采用 hash(key) % partitions 策略。
Kafka 集群中的服务节点,负责接收消息、存储分区、管理副本。
每个 Broker 持有多个 Partition 的部分数据。
Topic 是消息的逻辑分类,Partition 是物理存储单元。
Partition 数量决定了并行消费的上限。
每个 Partition 有 1 个 Leader 和 N-1 个 Follower。
所有读写操作都经过 Leader,Follower 异步同步。
与 Leader 保持同步的副本集合。acks=all 时需等待 ISR 全部确认才返回成功。
同一 Group 内的 Consumer 负载均衡消费 Partition。
不同 Group 可独立消费同一 Topic,互不影响。