同步数据回滚
MySQL 数据回滚→HBase 回滚:
MySQL 通过 binlog2sql 工具生成回滚 SQL,执行数据回滚;
Linux 下导出 HBase 指定版本数据(回滚前版本),重新写入:
hbase shell> scan 'hbase_t1', {TIMERANGE => [1735989600000, 1735993200000]} > /tmp/rollback_data.txt
解析文件并重新写入HBase
(2)同步链路故障恢复
Linux 下编写故障恢复脚本,支持一键回滚到最近可用的同步状态:
恢复步骤:停止同步→恢复MySQL数据→恢复HBase数据→重启同步
/usr/local/scripts/stop_sync.sh
mysql -h mysql-ip -u root -pMysql@123 < /tmp/mysql_rollback.sql
hbase org.apache.hadoop.hbase.mapreduce.Import hbase_t1 /tmp/hbase_backup
/usr/local/scripts/start_sync.sh