使用kafka consumer加载数据加载异常并且报source table and destination table are not same错误解决办法

现象

当服务器出现断电，磁盘写满等故障导致集群异常并手动恢复后，集群上运行的kafka consumer 任务可能出现停止加载的异常；

定位问题

查看集群gcluster的express日志，如果发现出现无法加载的表报source table and destination table are not same的异常日志，可以尝试以下方式解决；

解决办法

首先到gclusterdb库查询异常的kafka consumer任务的offset点位，记录下来

删除并重建异常的kafka consumer，将上一步记录的offset点位更新新建的kafka consumer任务上

最后启动重建的kafka consumer，查看日志是否还有报错，以及检查数据是否正常加载了