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:19:57 +08:00
parent 5891d29628
commit b7f4bf7182
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -54,7 +54,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
kfconfig := &kafka.ConfigMap{ kfconfig := &kafka.ConfigMap{
"bootstrap.servers": config.GetConf().KafkaUrl, // Kafka服务器地址 "bootstrap.servers": config.GetConf().KafkaUrl, // Kafka服务器地址
"group.id": config.GetConf().KafkaGroup, // 消费者组ID "group.id": config.GetConf().KafkaGroup, // 消费者组ID
"auto.offset.reset": "earliest", // 自动从最早的消息开始消费 "auto.offset.reset": "latest-offset", // 自动从最早的消息开始消费
"heartbeat.interval.ms": 1000, "heartbeat.interval.ms": 1000,
"session.timeout.ms": 45000, "session.timeout.ms": 45000,
"max.poll.interval.ms": 300000, // 5 分钟, 防止积压的时候认为掉线了 "max.poll.interval.ms": 300000, // 5 分钟, 防止积压的时候认为掉线了