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 {