Обновление Кафки 1 до Кафки 2

Question

Мы работаем с кластером Apache Kafka 1.1.0 с 5 брокерами.

Поскольку управление машинами осуществляется через Ansible, для нас самым простым способом обновления было бы перестроение брокеров один за другим с новой версией.

Основной вопрос заключается в том, могут ли некоторые брокеры с 1.1.0 и некоторые брокеры с 2.3.0 одновременно существовать в одном кластере?

Answer 1

Хотя это не лучшая практика, в одном кластере могут быть брокеры с разными версиями.Вам необходимо настроить inter.broker.protocol.version соответственно:

Укажите, какая версия протокола межброкерского взаимодействия будет использоваться.Обычно это происходит после обновления всех брокеров до новой версии.Пример некоторых допустимых значений: 0.8.0, 0.8.1, 0.8.1.1, 0.8.2, 0.8.2.0, 0.8.2.1, 0.9.0.0, 0.9.0.1 Проверьте ApiVersion для полного списка.

Однако, если между старшей и последней версиями существует огромный разрыв, вы можете столкнуться с проблемами совместимости (или другими).

Раздел «Обновление с предыдущих версий» в документах Kafka должен пролить немного света.