diff --git a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java index 1a15a8fa..fcbe69ad 100644 --- a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java +++ b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java @@ -433,9 +433,7 @@ public class MQMessageUtils { } } // update操作将记录修改前的值 - if (!rowOld.isEmpty()) { - old.add(rowOld); - } + old.add(rowOld); } } if (!sqlType.isEmpty()) {