Кафка топик не умеет назначать лидеров после создания

Question

Я использовал тему Кафки, и это также метаданные в моем приложении.Я тяжело удалил тему из оболочки zookeeper, удалив каталоги, соответствующие этой теме.После создания темы я описал ее и обнаружил, что для этой вновь созданной темы не назначены лидеры.У потребителя я вижу многократные печати журналов LEADER_NOT_AVAILABLE.Любая причина того, что я делаю не так?Или, может быть, есть способ удалить метаданные, связанные с темой kafka, о которых я не знаю?Заранее спасибо!

Answer 1

Удаление тем в Кафке не было простым до недавнего времени.В общем, вы не должны пытаться удалять темы Kafka, удаляя метаданные в Zookeeper.Вы всегда должны использовать включенные утилиты командной строки.

Сначала необходимо убедиться, что удаление тем включено в файле server.properties на всех посредниках, и при необходимости выполнить повторный перезапуск:

delete.topic.enable=true

После того, как вы перезапустите посредников, чтобы разрешить удаление тем, вы должны выполнить команду delete с помощью утилит командной строки:

./kafka-topics.sh —zookeeper <zookeeper_host>:2181 —delete —topic <topic_name>

Если в этот момент он все еще завис, попробуйте запустить этидве команды из оболочки zookeeper для проверки и удаления всех метаданных для этой конкретной темы:

rmr /brokers/topics/<topic_name>
rmr /admin/delete_topics/<topic_name>

Еще несколько подробностей здесь:

https://medium.com/@contactsunny/manually-delete-apache-kafka-topics-424c7e016ff3