修改反序列化方式

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

@@ -167,7 +167,7 @@ public class RootCloudIotDataReceiptedEvent implements Serializable {
     private Online __online__;
 
     @JsonProperty("__thingName__")
-    private Object thingName;
+    private String thingName;
 
     @Data
     public static class Online {

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

@@ -26,8 +26,8 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese
     @Override
     public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException {
 
-        log.info("接受的信息：{}", StrUtil.str(message, CharsetUtil.UTF_8));
-        return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
+        return JSONUtil.toBean(StrUtil.str(message, CharsetUtil.UTF_8), RootCloudIotDataReceiptedEvent.class);
+        //return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
     }
 
     @Override