【发布时间】：2021-08-18 08:40:11
【问题描述】：
我们正在为 Kafka 消息使用无注册的 Avro 模式所以我们有我们的自定义 Avro 转换器 由于我们没有可用的模式注册表
问题是当我们用新元素升级架构时，旧架构既不向后也不向前兼容
【问题讨论】：
-
你的问题是什么？
标签： java apache-kafka avro
【发布时间】：2021-08-18 08:40:11
【问题描述】：
Kafka 是一个实现细节
如果读取器架构与写入器架构不兼容，则 Avro 反序列化将失败。除了使用不同的架构之外，您无法解决此问题。
您现在知道为什么拥有一个能够在将数据放入 Kafka 之前执行兼容性检查的注册表很重要
【讨论】：
-
感谢您的快速回复
-
请在docs.confluent.io/platform/current/schema-registry/avro.html下方找到此链接。在这里，您可以将模式设置为完全可传递的，并在模式上执行增量更改，而不会破坏 Kafka 的旧模式。我们如何使用我们的自定义 Avro 转换器和没有模式注册表来执行相同的操作
-
那个兼容性逻辑只作为Registry的一部分存在...欢迎大家看源码复制出来
-
谢谢，我的问题更多是关于它的一部分
-
你是想让我把你链接到源代码吗？我个人无法解释它是如何工作的逻辑