Kafka Schema Registry 与 Avro 兼容性策略实战

--- title: Kafka Schema Registry 与 Avro 兼容性策略实战 keywords: - Schema Registry - Avro - 兼容性 - 演进 - Producer/Consumer description: 使用 Schema Registry 管理 Avro 模式，介绍兼容性策略与生产者/消费者集成示例，保障演进与解耦。 tags: - Avro - Kafka - Producer/Consumer - Schema Registry - 兼容性 - 后端 - 消息队列 - 演进 categories: - 文章资讯 - 技术教程 --- # Kafka Schema Registry 与 Avro 兼容性策略实战 ## 兼容性模式 - backward：新模式兼容旧数据的读取 - forward：旧模式兼容新数据的读取 - full：同时兼容前后 - none：不校验兼容，风险高 ## 注册与查询（HTTP） ```http POST /subjects/items-value/versions {"schema":"{\"type\":\"record\",\"name\":\"Item\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"name\",\"type\":\"string\"}]}"} GET /subjects/items-value/versions/latest ``` ## 生产者集成（Java 示例） ```java Properties p = new Properties(); p.put("bootstrap.servers", "localhost:9092"); p.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); p.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer"); p.put("schema.registry.url", "http://localhost:8081"); ``` ## 演进建议 - 仅新增可选字段，避免删除或重命名 - 为新字段提供默认值，提升兼容性 ## 验证 - 通过 Schema Registry 的兼容性检查 API 验证模式更改 ## 总结 规范的模式管理与兼容策略能在快速迭代中保障生产消费解耦与数据可读性。