您好，这种情况需要您这边在source重启后恢复上一次checkponit在state中保存的offset读数据、
另外您为啥不直接使用flink-cdc消费mysql的binlog写入starrocks呢
