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 }