From 5891d29628602859764d5537a0d9e17f1470b239 Mon Sep 17 00:00:00 2001
From: "qiyunfanbo126.com" <815699>
Date: Thu, 23 Jan 2025 17:13:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=87=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/utils/mq/kafka_v2.go | 1 +
 1 file changed, 1 insertion(+)

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)