Невозможно обновить Kafka 0.8.2.2 до 0.10.0.0

Question

Попытка обновления с Kafka 0.8.x до Kafka 0.10.x

Я сделал все, что сказано в документах Kafka (http://kafka.apache.org/documentation.html#upgrade_10)

Но я до сих пор не вижу, как обновляется KafkaЯ сделал:

1. Вставьте "inter.broker.protocol.version" и "log.message.format.version" в server.properties
2. Остановить посредник -> обновить "inter.broker.protocol.version "иметь текущую версию Kafka -> start broker. Повторил это для всех посредников в кластере.
3. Обновил версию протокола до" 0.10.0.0 "и перезапустил всеброкеры.

Я не думаю, что когда-либо происходило обновление Kafka. Я все еще нахожу старые jar-файлы и не вижу новых сценариев bash, которые будут доступны при обновлении до 0.10.0.0

Не уверен, что я все сделал правильно.

Буду признателен за любую помощь.

Answer 1

Похоже, вы пропустили Шаг 2:

Обновите брокеров. Это можно сделать посреднику за один раз, просто отключив его, обновив код и перезапустив его.

После добавления inter.broker.protocol.version и log.message.format.version в конфигурацию для каждого брокера его необходимо остановить, установить новые JAR-файлы (для версии 1.0) и перезапустить.

Вы можете получить последнюю версию 1.0 JAR от http://kafka.apache.org/downloads#1.0.2