Kafka Mirrormaker和记录编码

问题描述

我正在尝试使用镜像制作器将一个主题一个集群复制到另一个集群 本主题配置有avro模式。

自从我尝试使用镜像制作器以来,我就开始在同一集群上从一个主题复制到另一个主题(有点笨,但这是为了了解如何使用镜像制作器) 效果很好。

一旦我能够做到这一点,我就使用相同的配置将它从一个群集迁移到另一个群集,现在目标主题中的记录已损坏,并且我不明白为什么。

我的序列化在两侧都配置为String。 看到编码问题时,我还在两侧尝试了ByteArray。

您对我为什么遇到此问题有任何见解吗?

感谢阅读

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)