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 16:52:33 +08:00
parent 46adc9c617
commit aa0864b3b5
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -103,8 +103,6 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
} else { } else {
//utils.Log(nil, "对列放开") //utils.Log(nil, "对列放开")
} }
time.Sleep(3 * time.Minute)
msg, err := consumer.ReadMessage(1 * time.Second) msg, err := consumer.ReadMessage(1 * time.Second)
if err == nil { if err == nil {
utils.Log(nil, "offset", msg.TopicPartition.Offset) utils.Log(nil, "offset", msg.TopicPartition.Offset)