canal 服务端运行一段时间会报如下错。不知道如何解决。

我程序启动连接canal 报错： something goes wrong with reason: something goes wrong with channel com.alibaba.otter.canal.server.exception.CanalServerException: ack error , clientId:1001 batchId:47 is not exist , please check

怎么解决？canal服务端我也重启了。运行了一下，过一阵程序启动还是继续会报错

下面是我的代码

while (true) { Message message = connector.getWithoutAck(1000); // 获取指定数量的数据 long batchId = message.getId(); int size = message.getEntries().size(); if (batchId == -1 || size == 0) { try { Thread.sleep(1000); } catch (InterruptedException e) {} } else { long beginTime = DateUtils.nowDateToTimestamp(); //逻辑:1先判断插入与更新2如果是状态已完成4，则获取数据。进行保存，存mongdb try { switchHandle(message.getEntries()); connector.ack(batchId); // 提交确认 } catch (Exception e) { //System.out.println("同步错误，需要回滚" + e.getMessage()); logger.error("同步错误，需要回滚", e); connector.rollback(batchId); continue; } long endTime = DateUtils.nowDateToTimestamp(); logger.info("此次同步时间是:" + (endTime - beginTime) + " ms"); } }

原提问者GitHub用户fanqinghui