备份方法
- 全量备份
- 工具1:kafka-dump
安装后执行命令:kafka-dump --bootstrap-server <集群地址> --output-dir <备份路径>。 - 工具2:kafka-backup(推荐)
安装后执行命令:kafka-backup --bootstrap-server <集群地址> --backup-dir <备份路径>。
- 工具1:kafka-dump
- 增量备份
- 依赖 kafka-backup 或 MirrorMaker 工具,仅备份自上次备份后的新增数据。
恢复方法
- 全量恢复
- 使用
kafka-backup恢复:kafka-backup --bootstrap-server <集群地址> --restore-dir <备份路径>。 - 或通过
kafka-console-producer.sh从备份文件导入数据。
- 使用
- 增量恢复
- 需结合全量备份,通过 MirrorMaker 同步增量数据到目标集群。
注意事项
- 操作前建议关闭Kafka服务,避免数据不一致。
- 定期测试备份恢复流程,确保数据可正常还原。
- 可通过增加副本因子(
replication.factor)提升数据可靠性。
工具推荐:优先使用 kafka-backup(支持增量备份,由Confluent提供),或结合 MirrorMaker 实现跨集群同步。
参考来源: