Kafka удаление темы не работает

Question

Я использую Kafka версии 0.8.2. В середине разработки я подумал, что мне может понадобиться удалить тему. Итак, что я сделал, я поместил следующую строку в файлы конфигурации сервера и запустил два сервера kafka.

delete.topic.enable=true 

Когда мне нужно было удалить тему, и я побежал следующую команду,

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

Сейчас его уже 17 часов с момента, когда я пытался удалить команду тему, но Кафка все еще показывает мне тему помечается для удаления. Это ошибка Кафки, или я что-то не так здесь делаю? Потому что это не кажется мне нормальным. Может ли кто-нибудь прояснить в этом отношении?

[N.B .: Я уже прочитал this thread. Но не смог найти ответ.]

Answer 1

AFAIK нельзя удалить тему kafka, если у вас ранее был delete.topic.enable=false. Вы можете изменить это значение, но оно не влияет на доступные в настоящее время темы. Таким образом, вы можете попытаться удалить его вручную.

Answer 2

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