об этом так:
1. Обновите
server.properties
на всех брокерах и добавьте следующие свойства.
CURRENT_KAFKA_VERSION
относится к версии, с которой вы обновляетесь...
2. Обновляйте брокеров по одному: выключите брокера, обновите код и перезапустите его. Как только вы это сделаете, брокеры будут работать с последней версией, и вы сможете убедиться, что поведение и производительность кластера соответствуют ожиданиям...
3. После того, как поведение и производительность кластера будут проверены, измените версию протокола, отредактировав
inter.broker.protocol.version
и установив для нее значение X.X
4. Перезапустите брокеры по очереди, чтобы новая версия протокола вступила в силу.
Я туплю и не понимаю на каком этапе я должен собственно менять бинарники? На втором шаге?
Сразу фиксируете версию на всех брокерах. Потом уже обновляете по одному бинарники
Обсуждают сегодня