From 3271cea1b986ee24c5bfaf2b15326554fb56090c Mon Sep 17 00:00:00 2001
From: 独行的浪子 <871364441@qq.com>
Date: 星期一, 25 四月 2022 16:15:32 +0800
Subject: [PATCH] 睡眠一秒,防止ack未调用
---
README.md | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
diff --git a/README.md b/README.md
index 866e73b..e7eeab9 100644
--- a/README.md
+++ b/README.md
@@ -84,7 +84,7 @@
public void printChange(String method,CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
if (eventType == CanalEntry.EventType.DELETE) {
- rowData.getAfterColumnsList().stream().collect(Collectors.toList()).forEach(ele -> {
+ rowData.getBeforeColumnsList().stream().collect(Collectors.toList()).forEach(ele -> {
System.out.println("[鏂规硶: "+method+" , delete 璇彞 ] --->> 瀛楁鍚�: " + ele.getName() + ", 鍒犻櫎鐨勫�间负: " + ele.getValue());
});
}
--
Gitblit v1.8.0