From fb0cd7bd6e845874dac3204e6b26dda083b45b7b Mon Sep 17 00:00:00 2001
From: "qiyunfanbo126.com" <815699>
Date: Tue, 11 Feb 2025 16:13:12 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dkafka?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
app/utils/mq/kafka_v2.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index ad2d658..10bbd42 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -56,6 +56,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
group = config.GetConf().DidpatchKafkaGroup
}
kfconfig := &kafka.ConfigMap{
+ "api.version.request": "true",
"bootstrap.servers": config.GetConf().KafkaUrl, // Kafka服务器地址
"group.id": group, // 消费者组ID
"auto.offset.reset": "latest", // 自动从最早的消息开始消费earliest,latest