From 599e4b40d164dea8d6790a3414dcd6020c8e906e Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Mon, 13 Jan 2025 17:47:02 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/game/RegisterNetworkFunc.go | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/server/game/RegisterNetworkFunc.go b/src/server/game/RegisterNetworkFunc.go
index af52eb3e..226e0391 100644
--- a/src/server/game/RegisterNetworkFunc.go
+++ b/src/server/game/RegisterNetworkFunc.go
@@ -3446,12 +3446,12 @@ func ReqFriendTreasureEnd(args []interface{}) error {
 }
 
 func ReqKafkaLog(args []interface{}) error {
-	// _, player, buf := ParseArgs(args)
-	// req := &msg.ReqKafkaLog{}
-	// proto.Unmarshal(buf, req)
-	// // player.Kafka(req.Event, map[string]interface{}{
-	// // 	"data": req.Data,
-	// // })
+	_, player, buf := ParseArgs(args)
+	req := &msg.ReqKafkaLog{}
+	proto.Unmarshal(buf, req)
+	player.Kafka(req.Event, map[string]interface{}{
+		"data": req.Data,
+	})
 	return nil
 }