Topi c удаление из Zookeeper

Question

Я удалил topi c непосредственно из Zookeeper, используя приведенную ниже команду, и раньше не выполнял удаление из Kafka:

zookeeper-shell.sh localhost:2181 rmr /brokers/topics/<topic_name>

Теперь я вижу, что topi c отображается в log.dirs хотя бы одного брокера в кластере. Есть ли способ, который также может быть удален.

Когда я пытаюсь удалить из Кафки, теперь он выдает ошибку ниже

Error while executing topic command : Topic <topic_name> does not exist on ZK path <zookeeper_server_list:2181>

Answer 1

Я думаю, что вы пропустили пару шагов. Чтобы вручную удалить топи c, необходимо выполнить следующие действия:

1) Остановить сервер Kafka

2) На каждом брокере у вас есть удалить все файлы журнала topi c в logs.dirs:

rm -rf path/to/logs/topic_name/

3) Удалить каталог topi c из Zookeeper:

> zookeeper-shell.sh localhost:2181
> ls /brokers/topics
> rmr /brokers/topics/topic_name

4) Перезапустить Kafka сервер

---

Обратите внимание, что рекомендуемый способ удаления топи c -

/bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic topic_name

при условии delete.topic.enable=true.