运行客户端 batchId偶尔出现冲突问题

batchId:2176966 is not the firstly:2176965 at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.receiveMessages(SimpleCanalConnector.java:302) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.getWithoutAck(SimpleCanalConnector.java:279) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.getWithoutAck(SimpleCanalConnector.java:252) at com.yagou.yggx.provider.datasync.start.AbstractCanalStart.process(AbstractCanalStart.java:115)

下面是代码：

int batchSize = 5 * 1024; while (running) { try { MDC.put("destination", destination); connector.connect(); connector.subscribe(); while (running) { // 获取指定数量的数据 Message message = connector.getWithoutAck(batchSize); long batchId = message.getId(); int size = message.getEntries().size(); List entrys = message.getEntries(); if (batchId == -1 || size == 0) { // try {Thread.sleep(1000); // } catch (InterruptedException e) { } } else { DataSourceListenerInformation.comeOutEntry(entrys); } connector.ack(batchId); // 提交确认

原提问者GitHub用户youngJavabird