---

title: Kafka Schema Registry 兼容性与模式演进实践

keywords: compatibility, BACKWARD, FULL, subjects, versions, Avro

description: 配置全局与主题级兼容性策略,注册 Avro 模式并验证兼容性,安全演进事件结构。

tags:

  • Avro
  • BACKWARD
  • FULL
  • Kafka
  • SchemaRegistry
  • compatibility
  • subjects
  • versions
  • 数据流

categories:

  • 文章资讯
  • 技术教程

---

设置全局兼容性:

PUT http://schema-registry:8081/config
{
  "compatibility": "BACKWARD"
}

为主题设置兼容性:

PUT http://schema-registry:8081/subjects/orders-value/config
{
  "compatibility": "FULL"
}

注册 Avro 模式:

POST http://schema-registry:8081/subjects/orders-value/versions
{
  "schema": "{\"type\":\"record\",\"name\":\"Order\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"amount\",\"type\":\"double\"}]}"
}

验证兼容性:

POST http://schema-registry:8081/compatibility/subjects/orders-value/versions/latest
{
  "schema": "{\"type\":\"record\",\"name\":\"Order\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"amount\",\"type\":\"double\"},{\"name\":\"currency\",\"type\":\"string\",\"default\":\"USD\"}]}"
}

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论
立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部