From ce0dd22425336315bd1e11c4ab37bb3180122d81 Mon Sep 17 00:00:00 2001
From: "qiyunfanbo126.com" <815699>
Date: Tue, 11 Feb 2025 16:10:55 +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 | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index 3a2e400..ad2d658 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -58,13 +58,13 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 	kfconfig := &kafka.ConfigMap{
 		"bootstrap.servers":     config.GetConf().KafkaUrl, // Kafka服务器地址
 		"group.id":              group,                     // 消费者组ID
-		"auto.offset.reset":     "earliest",                // 自动从最早的消息开始消费earliest,latest
+		"auto.offset.reset":     "latest",                  // 自动从最早的消息开始消费earliest,latest
 		"heartbeat.interval.ms": 1000,
 		"session.timeout.ms":    45000,
 		"max.poll.interval.ms":  300000, // 5 分钟, 防止积压的时候认为掉线了
 		"enable.auto.commit":    false,
 	}
-
+	kfconfig.SetKey("security.protocol", "plaintext")
 	defer func() {
 		if err := recover(); err != nil {
 			fmt.Println("消费中断", err)