kafka通过consumer group实现单播与广播：单播由同组内consumer独占分区实现，广播则依赖不同group id独立消费同一topic。broker仅存一份日志，各group维护独立offset，确保隔离性与灵活性。
消费者组（Consumer Group）是 Kafka 实现消息分发语义的核心抽象，它不依赖底层复制或网络组播，而是靠协调机制与分区分配策略来决定“谁消费哪条消息”。单播和广播不是 Kafka 协议层面的两种传输方式，而是同一套机制在不同组配置下呈现出的两种逻辑行为。
Consumer Group 是逻辑订阅单元，不是物理集群
每个 Consumer Group 对应一个独立的订阅视角。Kafka 的 Topic 数据不会为每个 Group 实际复制多份，而是通过元数据记录每个 Group 当前消费到哪个 offset。Broker 只存一份原始日志，但允许不同 Group 各自维护自己的消费进度。这意味着：
- 多个 Group 订阅同一个 Topic，彼此完全隔离，互不影响
- Group 内部的多个 Consumer 实例共享消费进度，共同瓜分该 Group 能访问的分区
- Group ID 是唯一标识，哪怕只有一个 Consumer 实例，只要 Group ID 不同，就视为独立订阅者
单播：靠 Group 内部的分区独占分配实现
当多个 Consumer 属于同一个 Group 时，Kafka 的 Group Coordinator 会触发 Rebalance，把 Topic 的所有 Partition 均匀分配给这些 Consumer。每个 Partition 在同一时刻只由该 Group 中的一个 Consumer 拉取——这是“单播”效果的来源。
- 例如：Topic 有 4 个 Partition，Group A 有 2 个 Consumer，则大概率各分得 2 个 Partition
- Partition 分配由客户端 assignor（如 RangeAssignor 或 RoundRobinAssignor）完成，结果会上报给 Coordinator
- 只要 Group 成员稳定，分配关系就稳定；成员增减会触发 rebalance，重新分配
广播：靠多个独立 Group 实现“一写多读”
Kafka 本身不提供真正的网络层广播，所谓“广播”，是指让每个 Consumer 都拿到全量消息。做法很简单：每个 Consumer 使用不同的 Group ID 订阅同一个 Topic。
- 每个 Group 独立获得全部 Partition 的读取权限，各自从头或从指定 offset 开始消费
- 比如服务 A、B、C 都要更新本地缓存，就分别用 group-a、group-b、group-c 订阅 config-topic
- 消息体不重复存储，但每个 Group 的 offset 状态独立保存在 __consumer_offsets 主题中
关键细节决定行为是否可靠
广播看似简单，但实际落地要注意几个隐性约束：
- Consumer 必须显式设置 unique group.id，不能复用默认值或空字符串
- 如果多个进程误用了相同 group.id，它们会互相踢出，导致“伪广播”失效
- 广播场景下无需关注 Partition 数量与 Consumer 数量的关系，因为每个 Group 是独立消费全量
- offset 提交策略影响广播一致性：自动提交可能丢消息，手动提交需确保每个 Consumer 正确 commit
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
