apache-kafka - Kafka Mirrormaker 和记录编码

我正在尝试使用镜像制造商将主题从一个集群复制到另一个集群此主题配置有 avro 模式。

由于我正在尝试使用mirror maker，因此我开始在同一个集群上从一个主题复制到另一个主题（有点愚蠢，但它是为了了解如何使用mirror maker）它工作得很好。

一旦我能够做到这一点，我就使用相同的配置从一个集群到另一个集群，现在目标主题中的记录有损坏的字符，我不明白为什么。

我的序列化在两边都配置为字符串。当我看到编码问题时，我也尝试了两边的 ByteArray。

您对我为什么有这个问题有任何见解吗？

谢谢阅读

标签： apache-kafkaavroapache-kafka-mirrormaker