From d79ff003ca2ca835ab74bdff3978611a707a5a18 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Fri, 3 Jan 2025 15:17:36 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=A5=E5=BF=97=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E7=9A=84=E9=95=BF=E5=BA=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/game/LogMgr.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/server/game/LogMgr.go b/src/server/game/LogMgr.go
index 364b6906..e15dcd40 100644
--- a/src/server/game/LogMgr.go
+++ b/src/server/game/LogMgr.go
@@ -15,6 +15,7 @@ const (
 )
 const (
 	PLAYROOM_LOST = "playroom_lost"
+	LOG_LENGTH    = 10000
 )
 
 type LogMgr struct {
@@ -36,6 +37,14 @@ func (L *LogMgr) InitManager() {
 	L.McronSave.AddFunc("@every 10s", func() {
 		L.Lock.Lock()
 		defer L.Lock.Unlock()
+		if kafkaMiddleware.KafkaMod == nil {
+			if len(L.L) > LOG_LENGTH {
+				L.L = L.L[:0]
+			} else if len(L.L) > LOG_LENGTH {
+				L.L = L.L[len(L.L)-LOG_LENGTH:]
+			}
+			return
+		}
 		for _, v := range L.L {
 			value, _ := json.Marshal(v)
 			kafkaMiddleware.SendMsg([]byte(v.EventName), value)