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)