现象
当服务器出现断电,磁盘写满等故障导致集群异常并手动恢复后,集群上运行的kafka consumer 任务可能出现停止加载的异常;
定位问题
查看集群gcluster的express日志,如果发现出现无法加载的表报source table and destination table are not same的异常日志,可以尝试以下方式解决;
解决办法
首先到gclusterdb库查询异常的kafka consumer任务的offset点位,记录下来
删除并重建异常的kafka consumer,将上一步记录的offset点位更新新建的kafka consumer任务上
最后启动重建的kafka consumer,查看日志是否还有报错,以及检查数据是否正常加载了