From 59e5cfb04d081fc51d3a7bfccb6f984f9f78614e Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Mon, 2 May 2022 19:45:32 +0800 Subject: [PATCH] group chat log --- internal/rpc/msg/send_msg.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/rpc/msg/send_msg.go b/internal/rpc/msg/send_msg.go index 0a8f10dcf..f27a03476 100644 --- a/internal/rpc/msg/send_msg.go +++ b/internal/rpc/msg/send_msg.go @@ -279,8 +279,8 @@ func (rpc *rpcChat) SendMsg(_ context.Context, pb *pbChat.SendMsgReq) (*pbChat.S groupPB.MsgData.RecvID = v isSend := modifyMessageByUserMessageReceiveOpt(v, groupID, constant.GroupChatType, &groupPB) if isSend { - log.Debug(groupPB.OperationID, "sendMsgToKafka, ", v, groupID, groupPB.String()) msgToMQGroup.MsgData = groupPB.MsgData + log.Debug(groupPB.OperationID, "sendMsgToKafka, ", v, groupID, msgToMQGroup.String()) err := rpc.sendMsgToKafka(&msgToMQGroup, v) if err != nil { log.NewError(msgToMQGroup.OperationID, "kafka send msg err:UserId", v, msgToMQGroup.String())