Update DmlMessageTransponderContainer.java

独行的浪子

2022-04-26 3ad94b9abcbde117c6d6ce43a9d023b7755ec0eb

Update DmlMessageTransponderContainer.java

 src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java

@@ -64,14 +64,16 @@
            sleep(endpointInstance.getAcquireInterval());

            return;

        }

        for (CanalEntry.Entry entry : entries) {

        try {

            entries.forEach(e -> consumer(e));

                consumer(entry);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("[MessageTransponderContainer_doStart] CanalEntry.Entry consumer error ", e);

            // connector.rollback(message.getId()); // 目前先不处理失败, 无需回滚数据

            // return;

        }

        }

        connector.ack(message.getId()); // 提交确认

    }