From 2bd420861353f72f2f3e5e1c62e6904e4d89f175 Mon Sep 17 00:00:00 2001
From: mrproliu <741550557@qq.com>
Date: Tue, 19 Nov 2024 12:04:52 +0900
Subject: [PATCH] fix protocol analyzer not added to the connection issue

---
 pkg/accesslog/collector/protocols/queue.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/accesslog/collector/protocols/queue.go b/pkg/accesslog/collector/protocols/queue.go
index 034f945f..e505d3e9 100644
--- a/pkg/accesslog/collector/protocols/queue.go
+++ b/pkg/accesslog/collector/protocols/queue.go
@@ -133,7 +133,7 @@ func newPartitionConnection(protocolMgr *ProtocolManager, conID, randomID uint64
 }
 
 func (p *PartitionConnection) appendProtocolIfNeed(protocolMgr *ProtocolManager, conID, randomID uint64, protocol enums.ConnectionProtocol) {
-	if _, exist := protocolMgr.protocols[protocol]; !exist {
+	if _, exist := p.protocol[protocol]; !exist {
 		analyzer := protocolMgr.GetProtocol(protocol)
 		p.protocol[protocol] = true
 		p.protocolAnalyzer[protocol] = analyzer