Кафка Тема Сообщение Версии

Question

Я публикую сообщения в теме кафки (outputTopic) в формате, понятном моим подписчикам.Теперь я хочу изменить формат этих сообщений таким образом, чтобы это нарушало существующие темы.

Например, я публикую объекты, сериализованные в формате json, но мне нужно изменить объекты и, следовательно, схему.

Каков наилучший способ управлять этим типом изменений?Должен ли я изменить производителя так, чтобы он публиковался в новой теме (outputTopic2)?Есть ли лучшие способы справиться с этим?

Answer 1

Один простой способ сделать по мне, это использовать Реестр схемы / Apache Avro .В зависимости от того, как вы его используете, это поможет вам гарантировать обратную / прямую совместимость.