Debian Kafka数据恢复方法如下:
sudo systemctl stop kafka。kafka-dump备份,将备份文件复制回Kafka数据目录(默认/var/lib/kafka/data),重启服务:sudo cp /backup/path/* /var/lib/kafka/data/sudo systemctl start kafka。kafka-backup备份,执行恢复命令并指定备份目录:kafka-backup --bootstrap-server localhost:9092 --backup-dir /backup/path --restore-to /var/lib/kafka/datamirror-maker.properties,指定源集群和目标集群地址。kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config consumer.properties --producer.config producer.properties --whitelist "topic1|topic2"。sudo systemctl start kafka。kafka-backup(推荐)支持增量备份,kafka-dump适合全量备份。kafka-console-consumer.sh消费目标主题数据,确认恢复正确性。参考来源: