diff --git a/internal/rpc/msg/send_msg.go b/internal/rpc/msg/send_msg.go index 5f86c39d5..7897d3f3d 100644 --- a/internal/rpc/msg/send_msg.go +++ b/internal/rpc/msg/send_msg.go @@ -831,7 +831,8 @@ func (rpc *rpcChat) sendMsgToGroupOptimization(list []string, groupPB *pbChat.Se isSend := modifyMessageByUserMessageReceiveOpt(v, groupPB.MsgData.GroupID, constant.GroupChatType, groupPB) if isSend { if v == "" || groupPB.MsgData.SendID == "" { - panic(groupPB.OperationID) + log.Error(msgToMQGroup.OperationID, "sendMsgToGroupOptimization userID nil ", msgToMQGroup.String()) + continue } err := rpc.sendMsgToKafka(&msgToMQGroup, v, status) if err != nil {