java - 与 Avro 模式的向后和向前兼容性

首页 > 解决方案 > 与 Avro 模式的向后和向前兼容性

问题描述

我们正在为 Kafka 消息使用无注册表 Avro 模式所以我们有我们的自定义 Avro 转换器因为我们没有可用的模式注册表

问题是当我们用新元素升级模式时，旧模式不向后或向前兼容

标签： javaapache-kafkaavro

解决方案

Kafka是一个实现细节

如果读取器模式与写入器模式不兼容，则 Avro 反序列化将失败。除了使用不同的架构之外，您无能为力。

您现在知道为什么拥有一个能够在将数据放入 Kafka 之前执行兼容性检查的注册表很重要

推荐阅读