schema-registry

Confluent Schema Registry 管理

补充说明

Schema Registry 为 Kafka 消息提供 Avro/Protobuf/JSON Schema 的集中存储和兼容性检查。它用 REST API 管理 subject、版本和兼容策略，元数据存在 Kafka 内部 topic。

常用示例

curl -s http://schema-registry:8081/subjects
curl -s http://schema-registry:8081/subjects/app-value/versions
curl -s http://schema-registry:8081/subjects/app-value/versions/latest
curl -s http://schema-registry:8081/schemas/ids/1
curl -s http://schema-registry:8081/config

注册 schema：

curl -X POST http://schema-registry:8081/subjects/app-value/versions \
  -H 'Content-Type: application/vnd.schemaregistry.v1+json' \
  -d '{"schema":"{\"type\":\"record\",\"name\":\"App\",\"fields\":[{\"name\":\"id\",\"type\":\"int\"}]}"}'

兼容性配置

curl -X PUT http://schema-registry:8081/config/app-value \
  -H 'Content-Type: application/vnd.schemaregistry.v1+json' \
  -d '{"compatibility":"BACKWARD"}'

常见模式：BACKWARD、FORWARD、FULL、NONE。

易错点与排错

• 兼容模式决定新版本能否注册；改模式前确认所有消费者都能处理。
• subject 命名通常由 topic 和 key/value 决定；写错会注册到错误 subject。
• 删除 subject 默认是软删除；彻底删除需要 ?permanent=true，且不可恢复。
• Schema Registry 依赖 Kafka 存储元数据；Kafka 不可用时注册和查询都会失败。
• 多实例要共享同一 Kafka 集群和配置；否则 schema ID 会不一致。
• 认证、TLS 和 ACL 配置错误会表现为 401/403 或连接失败。
• Schema 演进要避免删除必填字段、改变类型等破坏性变更。

相关命令

• kafka-broker — 底层 Kafka
• ksql — 使用 schema 的流处理
• kcat — 消息验证

读完自测

合上页面，先回答，再展开对照。

1. 新 schema 注册被拒绝，先看什么？
2. 删除 subject 后为什么还能查到？
3. 多实例部署 Schema Registry 的关键前提是什么？