Kafka 主题消息版本控制

Question

我以订阅者可以理解的格式将消息发布到 kafka 主题 (outputTopic)。我现在希望以破坏现有主题消费者的方式修改这些消息的格式。

例如，我发布以 json 格式序列化的对象，但需要更改对象，因此需要更改架构。

管理此类变更的最佳方法是什么？我应该改变生产者以便它发布到新主题（outputTopic2）吗？有没有更好的方法来管理这个问题？

Answer 1

根据我的说法，一种干净的方法是使用Schema 注册表/ Apache Avro。根据您使用它的方式，它将帮助您保证向后/向前兼容性。