commit

src/main/java/com/cxzx/canal/CanalClientMain.java

@@ -200,17 +200,14 @@ public class CanalClientMain {
         }
 
         var newData = new JSONObject();
-        var changeColumn = new JSONArray();
         for (CanalEntry.Column column : rowData.getAfterColumnsList()) {
-            newData.put(column.getName(), column.getValue());
             if (column.getUpdated()) {
-                changeColumn.add(column.getName());
+                newData.put(column.getName(), column.getValue());
             }
         }
 
         root.put("old", oldData);
         root.put("new", newData);
-        root.put("change", changeColumn);
 
 
         logItem.PushBack("data", root.toString());