Как удалить тему, которая запускается в многоуровневом многоуровневом кластере HA kafka

Question

Я установил kafka версию 2.11-0.10.1.0 в многоуровневую многокластерную среду. В kafka server.properties я уже добавил delete.enable.topic = true в все 3 машины.

Я использую команду для удаления темы есть ./bin/kafka-topic.sh --zookeeper ip1: 2181, ф2: 2181, IP3: 2181 --delete --topic topicname

но он не удаляется, показывая название темы-метки для удаления

Так что каждый раз я очищаю журналы кафки и журнальные записи для удаления темы.

У кого-нибудь есть идея удалить с помощью командной строки.

Answer 1

В общем, все, что вы делаете, звучит правильно, я подозреваю, что ваша проблема - простая опечатка.

Параметр, чтобы включить тему делеции в Кафке называется: delete.topic.enable не так, как Вы сказали выше: delete.enable.topic.

Это приведет к тому, что удаление вернется к своему значению по умолчанию, которое равно false и приведет к поведению, которое вы видите.

Исправление этого и перезапуска должно исправить вашу проблему и удалить все темы.