diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index 6dddb7c..c531aa6 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -133,6 +133,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 					} else {
 						fmt.Println(mqsg.Key)
 					}
+
 					var data, _ = json.Marshal(mqsg)
 					_, err = redis.GetRedis().HSet(context.Background(), "kafka_message", string(msg.Key), data).Result()
 					err = handler(0, nil, data)