From 2c62f5d38a4aa589e74eac78eebdff8d62f36919 Mon Sep 17 00:00:00 2001
From: "qiyunfanbo126.com" <815699>
Date: Wed, 22 Jan 2025 13:50:59 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E7=9F=AD=E7=BA=BF=E5=90=8Ecp?=
 =?UTF-8?q?u=E9=A3=99=E5=8D=87=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/utils/mq/kafka_v2.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index b9bce05..84cf6f4 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -95,7 +95,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 		go func() {
 			for {
 				if atomic.LoadInt32(tcppool.TcpFactory.Full) == 1 {
-					utils.Log(nil, "对列阻塞")
+					//utils.Log(nil, "对列阻塞")
 					time.Sleep(100 * time.Millisecond)
 					continue
 				} else {