更新

root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java

@@ -1,6 +1,7 @@
 package com.qniao.iot.rc;
 
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import lombok.Data;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty;
 
@@ -165,8 +166,8 @@ public class RootCloudIotDataReceiptedEvent implements Serializable {
 
     private Online __online__;
 
-    @JsonProperty(value = "__thingName__")
-    private String thingName;
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    private String __thingName__;
 
     @Data
     public static class Online{

root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java

@@ -23,7 +23,6 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese
     @Override
     public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException {
 
-        log.info("接受的设备数据：{}", JSONUtil.toJsonStr(message));
         return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
     }