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