diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index a0a620b..4ccd72b 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -98,12 +98,14 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 					var mqsg = entities.MqMessage{}
 					mqsg.Key = string(msg.Key)
 					mqsg.Property = make(map[string]interface{})
-					if false {
-						for _, v := range msg.Headers {
-							if v.Key == "property" {
-								json.Unmarshal(v.Value, &mqsg.Property)
+					if len(msg.Value) > 0 {
+						if msg.Headers != nil {
+							for _, v := range msg.Headers {
+								if v.Key == "property" {
+									json.Unmarshal(v.Value, &mqsg.Property)
+								}
+								mqsg.Property[string(v.Key)] = string(v.Value)
 							}
-							mqsg.Property[string(v.Key)] = string(v.Value)
 						}
 						err = json.Unmarshal(msg.Value, &mqsg.Body)
 					} else {