diff --git a/consumers/consumerAXYraw.go b/consumers/consumerAXYraw.go index ccc79dd..3121994 100644 --- a/consumers/consumerAXYraw.go +++ b/consumers/consumerAXYraw.go @@ -149,7 +149,7 @@ func (the *consumerAXYraw) onData(topic string, msg string) bool { needPush := adaptor.Transform(topic, msg) - if needPush != nil && len(needPush.Meta) > 0 { + if needPush != nil && len(needPush.Meta) > 0 && needPush.Data != nil { //日志标记 if needPush.IotaDevice == logTagDeviceId { bs, _ := json.Marshal(needPush)