问题描述
我使用 Debezium MysqL 连接器和 Avro 数据格式来实现发件箱模式。我的表中的payload列是tinyblob(字节)格式,它是从Avro payload序列化的。消费者可以使用其原始模式读取字节数据(有效负载列)。
现在,我想做一个模式演变,让消费者使用不同的模式读取字节。如果我让消费者直接用第二个模式读取字节,就会出现错误/不匹配的情况。我认为这是因为我将 Avro 负载本身转换为没有架构的字节。
除了将第一个模式作为列存储到数据库中并让消费者使用第一个模式列反序列化有效负载之外,是否有任何建议或建议让我在不停止的情况下读取消费者中的第二个模式的字节生产者和消费者在一起?或者,是否有更好的方法将架构和有效负载存储到数据库中。非常感谢!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)