4. Schema Registry 介绍：Schema Registry 的作用、存储结构、版本管理、兼容性检查策略

在 Kafka 消息驱动的微服务架构中，生产者与消费者之间通过消息体（Payload）进行数据交换。一旦消息的 Schema（模式）发生变更（如新增字段、修改类型），若缺乏统一的注册与校验机制，极易导致消费者反序列化失败或数据错乱。Schema Registry 正是为解决这一核心问题而生的中央化 Schema 存储与治理服务。

4.1 Schema Registry 的核心作用

Schema Registry 作为 Kafka 生态中的关键组件，承担以下职责：

• Schema 集中存储与检索：为每个 Topic 或 Subject 维护一份 Schema 记录，生产者和消费者通过 Subject Name 获取对应的 Schema。
• 序列化与反序列化保障：配合 Avro、Protobuf、JSON Schema 等序列化器，在消息中嵌入 Schema ID，消费者根据 ID 从 Registry 拉取 Schema 完成反序列化。
• 版本管理与演进：每次 Schema 变更都会生成一个新版本，保留完整的历史版本链，支持按版本号或时间戳回溯。
• 兼容性校验：在注册新 Schema 时，根据预设的兼容性策略自动校验其与现有版本的兼容性，阻止不兼容的变更。
• 契约测试的基础设施：为消息契约提供可查询、可比较、可回溯的中央仓库，是契约测试中“版本回溯与校验”的核心数据源。

4.2 存储结构：Subject 与 Schema 的映射关系

Schema Registry 的存储模型围绕 Subject 和 Schema 两个核心概念构建。一个 Subject 通常对应一个 Kafka Topic 中的一种消息类型（如 value 或 key）。每个 Subject 下可以注册多个 Schema 版本。

下表展示了典型的存储结构：

以下 SVG 图展示了 Schema Registry 的内部存储结构及 Subject 与 Schema 版本之间的层级关系：

4.3 版本管理机制

Schema Registry 的版本管理遵循以下规则：

• 自动版本递增：每次向同一 Subject 注册新 Schema 时，Registry 自动分配下一个版本号（Version = max(Version) + 1）。
• 版本不可变：已注册的 Schema 版本不可修改或删除（默认配置），确保历史版本的可追溯性。
• 全局 Schema ID：每个 Schema 内容（无论属于哪个 Subject）都会获得一个全局唯一的整数 ID，用于消息序列化时的快速查找。
• 版本回溯：消费者可以指定消费特定 Schema 版本的消息，或使用兼容性策略自动选择可兼容的版本。

4.4 兼容性检查策略

Schema Registry 支持多种兼容性策略，用于控制 Schema 演进的严格程度。下表总结了各策略的定义与适用场景：

以下 SVG 图展示了 BACKWARD 与 FORWARD 两种核心兼容性策略的校验流程：

4.5 兼容性检查的底层规则

以 Avro Schema 为例，兼容性检查主要依据以下规则：

• 字段新增：新 Schema 可以新增字段，但必须提供默认值（BACKWARD 兼容）；旧 Schema 可以忽略新字段（FORWARD 兼容）。
• 字段删除：删除字段通常被视为不兼容变更，除非该字段在旧 Schema 中有默认值且策略允许。
• 字段类型变更：类型变更需要满足 Avro 的类型提升规则（如 int → long → float → double 是兼容的）。
• 字段重命名：Avro 支持通过别名（aliases）实现字段重命名的兼容性。
• 命名空间变更：修改命名空间通常被视为不兼容变更。

4.6 Schema Registry 在契约测试中的角色

在《基于 Kafka 的契约测试》课程体系中，Schema Registry 承担以下关键角色：

• 契约仓库：存储所有历史 Schema 版本，作为契约测试的“黄金标准”。
• 版本回溯引擎：测试框架通过 Registry API 获取指定版本的 Schema，构造对应格式的消息。
• 兼容性断言工具：测试用例可以调用 Registry 的兼容性检查 API，验证新 Schema 是否与旧版本兼容。
• 差异分析数据源：通过对比两个 Schema 版本的字段结构，自动生成契约差异报告。

以下代码示例展示了如何使用 Schema Registry REST API 注册 Schema 并检查兼容性：

# 注册新 Schema 并检查兼容性
curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
  --data '{
    "schema": "{\"type\":\"record\",\"name\":\"Order\",\"fields\":[{\"name\":\"orderId\",\"type\":\"string\"},{\"name\":\"amount\",\"type\":\"double\"},{\"name\":\"currency\",\"type\":\"string\",\"default\":\"USD\"}]}"
  }' \
  http://localhost:8081/subjects/order-events-value/versions

# 检查兼容性（不注册）
curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
  --data '{
    "schema": "{\"type\":\"record\",\"name\":\"Order\",\"fields\":[{\"name\":\"orderId\",\"type\":\"string\"},{\"name\":\"amount\",\"type\":\"double\"}]}"
  }' \
  http://localhost:8081/compatibility/subjects/order-events-value/versions/latest