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

修复kafka

This commit is contained in:
qiyunfanbo126.com 2025-02-11 16:13:12 +08:00
parent ce0dd22425
commit fb0cd7bd6e
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

@ -56,6 +56,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
group = config.GetConf().DidpatchKafkaGroup group = config.GetConf().DidpatchKafkaGroup
} }
kfconfig := &kafka.ConfigMap{ kfconfig := &kafka.ConfigMap{
"api.version.request": "true",
"bootstrap.servers": config.GetConf().KafkaUrl, // Kafka服务器地址 "bootstrap.servers": config.GetConf().KafkaUrl, // Kafka服务器地址
"group.id": group, // 消费者组ID "group.id": group, // 消费者组ID
"auto.offset.reset": "latest", // 自动从最早的消息开始消费earliest,latest "auto.offset.reset": "latest", // 自动从最早的消息开始消费earliest,latest