Kafka 如何解码MM2偏移同步主题中的消息？

ffvjumwh 于 2023-02-03 发布在 Apache

关注(0)|答案(1)|浏览(388)

参考KIP-382中包含的偏移同步主题（维护群集到群集的偏移Map），在使用来自mm2-offset-syncs.target.internal的消息时，发现它们被序列化。
1.有没有一种方法可以反序列化输出，使其可以理解使用Kafka命令行消费者？

./kafka-console-consumer.sh --bootstrap-server localhost:xxxx --topic mm2-offset-syncs.dest.internal --from-beginning

apache-kafka

来源：https://stackoverflow.com/questions/75278287/how-to-decode-messages-in-mm2-offset-sync-topic

1条答案

按热度按时间

mzillmmw1#

可以，您可以使用OffsetSyncFormatter来反序列化偏移同步主题的内容。例如：

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
  --topic mm2-offset-syncs.target.internal \
  --formatter org.apache.kafka.connect.mirror.formatters.OffsetSyncFormatter \
  --from-beginning

有关详细信息，请参见KIP-597: MirrorMaker2 internal topics Formatters

赞(0）回复(0）举报 2023-02-03

我来回答

Kafka 如何解码MM2偏移同步主题中的消息？

1条答案

相关问题

热门标签

最新问答