yunfantec
/
mq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加重

This commit is contained in:
qiyunfanbo126.com 2025-01-23 17:13:51 +08:00
parent aa0864b3b5
commit 5891d29628
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/utils/mq/kafka_v2.go
View File

@ -133,6 +133,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
} else { } else {
fmt.Println(mqsg.Key) fmt.Println(mqsg.Key)
} }
var data, _ = json.Marshal(mqsg) var data, _ = json.Marshal(mqsg)
_, err = redis.GetRedis().HSet(context.Background(), "kafka_message", string(msg.Key), data).Result() _, err = redis.GetRedis().HSet(context.Background(), "kafka_message", string(msg.Key), data).Result()
err = handler(0, nil, data) err = handler(0, nil, data)