avro - 架构注册表迁移 - 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?
解决方案
推荐阅读
- reactjs - 如何使用路由器和 Redux 渲染 react-testing-library?
- python - 如何在 Python 中多次调用函数?
- javascript - 使用 promise-pool 和 puppeteer 创建一个持续增加的列表
- c++ - 格式化输出,因此我使用 BFS 将其作为二叉树
- r - 从服务器中的两个 selectInputs 中,如何使一个依赖于另一个?
- javascript - primeng 列过滤器不适用于 Promise Values
- node.js - MongoDB:TypeError:无法读取 101 个文档后未定义的属性“getMore”
- ruby-on-rails - Rails 6为每个类别选择随机ActiveRecord对象
- c++ - 手动从类对象向量中排序数据 - C++
- python - 质疑这样的 Python 类是否正确