fix: continue when record data is null.

yanrongzhen · yanrongzhen · commit 803b0e726eb0 · 2023-11-15T21:07:10.000+08:00
diff --git a/eventmesh-connectors/eventmesh-connector-dingding/src/main/java/org/apache/eventmesh/connector/dingding/sink/connector/DingDingSinkConnector.java b/eventmesh-connectors/eventmesh-connector-dingding/src/main/java/org/apache/eventmesh/connector/dingding/sink/connector/DingDingSinkConnector.java
@@ -30,6 +30,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 
@@ -116,7 +117,10 @@ public boolean isRunning() {
     public void put(List<ConnectRecord> sinkRecords) {
         for (ConnectRecord record : sinkRecords) {
             try {
-
+                if (Objects.isNull(record.getData())) {
+                    log.warn("ConnectRecord data is null, ignore.");
+                    continue;
+                }
                 String accessToken = getAccessToken();
                 OrgGroupSendHeaders orgGroupSendHeaders =
                     new OrgGroupSendHeaders();
