📚 课程目录第3章 Kafka消息模型

3. Kafka 消息模型：点对点模型与发布订阅模型在 Kafka 中的实现

Kafka 作为一个分布式流处理平台，其消息模型设计兼具了传统消息队列的 点对点（Point-to-Point, P2P） 与 发布订阅（Publish-Subscribe, Pub/Sub） 两种核心模式。理解这两种模式在 Kafka 中的具体实现机制，是掌握 Kafka 契约测试与版本兼容性分析的基础。

3.1 核心概念回顾：Topic、Partition、Consumer Group

在深入模型之前，需要明确 Kafka 的四个核心抽象：

概念	说明	与消息模型的关系
Topic（主题）	消息的逻辑分类，类似数据库中的表。	两种模型共享同一个 Topic 存储。
Partition（分区）	Topic 的物理分片，是并行度的基本单位。	决定了消息的负载均衡与顺序性。
Consumer Group（消费组）	一组消费者的逻辑集合，组内消费者共同消费 Topic 消息。	点对点模型的核心载体。
Offset（偏移量）	消息在 Partition 内的唯一序号。	用于追踪消费进度，实现消息不丢失。

3.2 点对点模型（P2P）在 Kafka 中的实现

在传统消息队列中，点对点模型意味着一条消息只能被一个消费者消费。Kafka 通过 Consumer Group 机制完美复现了这一语义。

实现原理：将多个消费者实例注册到同一个 group.id 下。Kafka 协调器（Group Coordinator）负责将 Topic 下的所有 Partition 均匀分配给组内的消费者实例。
消息路由：一条消息写入某个 Partition 后，只会被该 Partition 的 唯一消费者 从该组中拉取并处理。
负载均衡：当组内消费者数量变化或 Partition 数量变化时，触发 Rebalance 重平衡，重新分配 Partition 归属。

  关键契约约束：在点对点模式下，契约测试需要验证 group.id 的一致性以及 Rebalance 策略（如 RangeAssignor、RoundRobinAssignor）是否导致 Partition 分配结果与预期相符。

3.3 发布订阅模型（Pub/Sub）在 Kafka 中的实现

发布订阅模型允许一条消息被多个独立的消费者处理。Kafka 通过 多个不同的 Consumer Group 来实现这一模式。

实现原理：每个 Consumer Group 都是一个独立的订阅者。Producer 将消息发布到 Topic，所有订阅了该 Topic 的 Consumer Group 都会收到该消息的副本。
消息广播：消息在 Kafka 层面只存储一份（在 Partition 中），但每个 Consumer Group 都会独立地维护自己的 Offset，从而独立地消费该消息。
隔离性：不同 Consumer Group 之间的消费进度完全隔离，互不影响。

实践要点：在微服务架构中，一个事件（如“订单创建”）通常需要被订单服务（点对点处理）、通知服务（发送短信）、数据分析服务（埋点）同时消费。此时，这三个服务应分别使用不同的 group.id，形成三个独立的发布订阅订阅者。

3.4 两种模型的对比与选择

对比维度	点对点模型（P2P）	发布订阅模型（Pub/Sub）
Kafka 实现方式	单个 Consumer Group	多个 Consumer Group
消息消费次数	每条消息仅被组内一个消费者消费一次	每条消息被每个 Group 消费一次
典型场景	任务分发、日志采集、异步解耦	事件广播、数据复制、多系统集成
消费者关系	竞争关系（互为备份）	独立关系（各取所需）
Offset 管理	组内共享 Offset 提交策略	每个 Group 独立管理 Offset

3.5 模型实现架构图

下图展示了 Kafka 如何通过 Consumer Group 的划分，在同一 Topic 上同时支持两种消息模型。

3.6 契约测试视角下的模型差异

在编写契约测试时，两种模型对消息的 幂等性、顺序性 和 消费语义 的验证要求不同：

点对点模型契约：必须验证在同一个 Group 内，同一 Partition 的消息不会被重复消费。测试用例应模拟 Rebalance 场景，确保 Partition 重新分配后，Offset 提交的原子性。
发布订阅模型契约：必须验证不同 Group 之间的消费隔离性。测试用例应创建两个独立的 Group，确认它们都能独立消费到全量消息，且 Offset 互不干扰。

常见陷阱：在契约测试中，如果只使用一个 Consumer Group 进行测试，只能验证点对点模型。若要验证发布订阅模型，必须显式创建至少两个不同的 group.id，并分别检查它们的消费进度。

3.7 代码示例：两种模型的消费者配置

以下 Java 代码片段展示了如何通过配置 group.id 来切换两种消息模型。

// 点对点模型：两个消费者属于同一个 Group
Properties p2pProps = new Properties();
p2pProps.put("bootstrap.servers", "localhost:9092");
p2pProps.put("group.id", "order-processing-group"); // 关键：相同 group.id
p2pProps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
p2pProps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

// 发布订阅模型：两个消费者属于不同的 Group
Properties pubSubPropsA = new Properties();
pubSubPropsA.put("group.id", "notification-group"); // Group A

Properties pubSubPropsB = new Properties();
pubSubPropsB.put("group.id", "analytics-group");    // Group B

3.8 本章小结

Kafka 通过 Consumer Group 这一核心抽象，在同一个 Topic 上同时实现了点对点与发布订阅两种消息模型。点对点模型依赖单 Group 内的 Partition 分配机制，实现消息的独占消费与负载均衡；发布订阅模型依赖多 Group 的 Offset 独立管理，实现消息的广播与多路分发。在契约测试中，必须根据业务场景明确选择对应的 Group 配置，并针对性地验证消费隔离性、Offset 提交原子性以及 Rebalance 行为。