This commit is contained in:
hahwu 2025-01-13 17:47:02 +08:00
parent 1b913664a5
commit 398e7208dc

View File

@ -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
}