如何使用 mirrormaker 反序列化 avro 消息？

Question

我想将 kafka 主题复制到 azure 事件中心。 消息采用 avro 格式，并使用模式注册表后面的模式，具有 USER_INFO 身份验证。

使用 java 客户端连接到 kafka，我可以使用 KafkaAvroDeserializer 正确反序列化消息。

但是这个配置似乎不适用于 mirrormaker。

是否可以在发送前使用 mirrormaker 反序列化 avro 消息？

干杯

Answer 1

对于 MirrorMaker1，consumer deserializer properties are hard-coded

除非您计划在生产者向 EventHub 发送数据时将数据 re-serializing 转换为不同的格式，否则您应该坚持使用默认的 ByteArrayDeserializer。

如果您确实想以任何方式操纵消息，则需要使用 MirrorMakerMessageHandler subclass

---

对于 MirrorMaker2，您可以使用 AvroConverter 后跟一些 transforms 属性，但对于 one-to-one 字节副本，ByteArrayConverter 仍然是首选。