日志优化
This commit is contained in:
parent
db9fb4ad85
commit
43a27e9eba
@ -3855,6 +3855,7 @@ func ReqKafkaLog(player *Player, buf []byte) error {
|
|||||||
req := &msg.ReqKafkaLog{}
|
req := &msg.ReqKafkaLog{}
|
||||||
proto.Unmarshal(buf, req)
|
proto.Unmarshal(buf, req)
|
||||||
player.Kafka(req.Event, map[string]interface{}{
|
player.Kafka(req.Event, map[string]interface{}{
|
||||||
|
"From": "Client",
|
||||||
"data": req.Data,
|
"data": req.Data,
|
||||||
})
|
})
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user