У нас есть 6 узлов кафки кластера. Из 6 машин 3 имеют Kafka + zookeeper, а остальные 3 имеют только Kafka. Недавно мы добавили еще один узел kafka. При переназначении раздела всем узлам (включая более новый) мы выполнили следующую команду:
/opt/kafka/bin/kafka-reassign-partitions.sh --reassignment-json-file new_assignment_details.json --execute --zookeeper localhost:2181
Однако, когда мы проверили состояние с помощью приведенной ниже команды,
/opt/kafka/bin/kafka-reassign-partitions.sh --reassignment-json-file new_assignment_details.json --verify --zookeeper localhost:2181
Мы получаем вывод ниже. Некоторые разделы переназначения еще не завершены.
/opt/kafka/bin/kafka-reassign-partitions.sh --reassignment-json-file new_assignment_details.json --verify --zookeeper localhost:2181 | grep 'progress'
Reassignment of partition [topic-name,854] is still in progress
Reassignment of partition [topic-name,674] is still in progress
Reassignment of partition [topic-name,944] is still in progress
Reassignment of partition [topic-name,404] is still in progress
Reassignment of partition [topic-name,314] is still in progress
Reassignment of partition [topic-name,853] is still in progress
Reassignment of partition [prom-metrics,403] is still in progress
Reassignment of partition [prom-metrics,134] is still in progress
Нет возможности либо:
- Отменить текущее переназначение раздела.
- Откат также невозможен. (Когда мы пытаемся сделать это, он говорит, что «Существующее задание выполняется.»
Kafka Версия: 0.10.1.1
Платформа: Amazon Linux 1 x86_64 GNU / Linux
Может кто-нибудь помочь мне в этом?