首页 > 解决方案 > 架构注册表迁移 - KSQL 错误 - SerializationException:检索 id x 的 Avro 架构时出错

问题描述

将 _schemas 主题从一个 (1) 数据中心复制到另一个数据中心 (2) 新的 _schemas_test 主题,并将第二个数据中心的模式注册表密钥库属性修改为 _schemas_test 主题。

在此之后,开始面临问题“SerializationException: Error retrieving Avro schema for id x”

由于与第一个数据中心相比,第二个数据中心的 ID 不同,因此这可能是正确的错误。验证错误中的“x”id 在第一个数据中心旧模式中有效。两个数据中心都运行相同的 ksql 查询和相同的主题。尝试更改架构然后恢复到旧版本,但没有修复错误。

有没有办法修复这些错误,以便第二个数据中心可以使用来自第一个数据中心的模式备份,反之亦然?生产者和消费者如何使用这些单调递增的 id 来使用 AVRO 格式进行序列化和反序列化?有没有办法根据模式注册表中每个主题的最新活动版本重置或刷新所有生产者和消费者的 ID?

标签: avroapache-kafka-connectconfluent-platformconfluent-schema-registryksqldb

解决方案


推荐阅读