Назад | Перейти на главную страницу

kafka + как отменить удаление темы

на всякий случай удаляем не ту тему как

 /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --zookeeper hdpmaster01:2181 --delete --topic gtom.poli.pri.proc

Тема gtom.poli.pri.proc уже отмечена для удаления, и теперь мы хотим вернуть ее

что нужно сделать, чтобы отменить удаление темы?

 all folders topics as the following are still exists under /var/kafka/kafka-logs

 gtom.poli.pri.procis-23

 gtom.poli.pri.procis-45

 gtom.poli.pri.procis-34

Мы сделали нечто подобное 3-4 года назад. Двоичные файлы в этих каталогах легко читаются, поэтому мы скопировали эти каталоги в другое место, написали простой код, который считывает данные и разделяет двоичные файлы, воссоздали тему и скармливали ей выводом из этого простого кода (даже bash, strings сделаю работу). В нашей ситуации проблема заключалась в повреждении диска, поэтому не все данные были восстановлены, а большая их часть.