From 3aa086f9bb62a7c338d7e19f7833db37de8d9b6a Mon Sep 17 00:00:00 2001
From: "qiyunfanbo126.com" <815699>
Date: Fri, 17 Jan 2025 21:01:08 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/http/tcppool/single.go | 2 ++
 app/utils/mq/kafka_v2.go   | 1 +
 2 files changed, 3 insertions(+)

diff --git a/app/http/tcppool/single.go b/app/http/tcppool/single.go
index f4ab20a..3449f01 100644
--- a/app/http/tcppool/single.go
+++ b/app/http/tcppool/single.go
@@ -28,6 +28,8 @@ func (t *TcpHelper) Init(port string) *TcpHelper {
 		if err == nil {
 			t.client = conn
 			t.watch(t.client)
+		} else {
+			utils.Log(nil, config.GetConf().Url+":"+port)
 		}
 	})
 	return t
diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index 08e3017..45563b5 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -51,6 +51,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 		"max.poll.interval.ms":  300000, // 5 分钟, 防止积压的时候认为掉线了
 		"enable.auto.commit":    false,
 	}
+	utils.Log(nil, "kafka config", kfconfig)
 	var start = time.Now()
 	var end time.Time
 	consumer, err := kafka.NewConsumer(kfconfig)