diff --git a/src/server/game/RegisterNetworkFunc.go b/src/server/game/RegisterNetworkFunc.go index aa7df5f4..9f172f98 100644 --- a/src/server/game/RegisterNetworkFunc.go +++ b/src/server/game/RegisterNetworkFunc.go @@ -3855,6 +3855,7 @@ func ReqKafkaLog(player *Player, buf []byte) error { req := &msg.ReqKafkaLog{} proto.Unmarshal(buf, req) player.Kafka(req.Event, map[string]interface{}{ + "From": "Client", "data": req.Data, }) return nil