☰

kafka + 如何恢复主题删除

tag-icon • tag-icon linux hadoop kafka
kafka + 如何恢复主题删除

以防我们删除错误的主题

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

主题 gtom.poli.pri.procis 已标记为删除，现在我们想将其还原

恢复主题删除的步骤是什么？

 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

答案1

我们在 3-4 年前做过类似的事情。这些目录中的二进制文件很容易读取，因此我们将这些目录复制到另一个位置，编写了一些简单的代码来读取二进制文件中的数据和分隔符，重新创建了一个主题，并用该简单代码的输出来输入它（即使是 bash 也strings可以完成这项工作）。在我们的情况下，问题在于磁盘损坏，因此并非所有数据都已恢复，大部分数据都已恢复。

相关内容