На данный момент я имею кластер кафки из 4 серверов с версией 2.4
Хотел бы уточнить правильную последовательность действий при обновлении.
1. Я скачал архив kafka_2.12-2.5.0.tgz, разархивировал, скопировал в папку kafka_2.12-2.5.0/configs конфиги кафки 2.4. server.properties, zookeeper.properties, producer.properties.
2. Остановил брокер на первой ноде, тоесть стопнул kafka.service и zookeeper.service
3. В конфиге в папки kafka_2.12-2.5.0/configs/ обновил server.properties и добавил следующие свойства.
inter.broker.protocol.version = 2.4
log.message.format.version = 2.4
тоесть укажу старую версию
4. Буду обновлять брокеров по одному на 4 нодах
5. После проверки поведения и производительности кластера изменю версию протокола
inter.broker.protocol.version = 2.5
6. Перезапущу брокеры по очереди, чтобы новая версия протокола вступила в силу
Все ли корректно? Что будет происходить с топиками и офсетами при обновлении кафки. Будет ли при отключении брокера и включении его в папке с новой версией также функционировать в кластере?
Средний
Средний
Сложный
