fix issue#15

.gitignore

@@ -0,0 +1 @@
+.devcontainer/

src/rpc/chat/chat/send_msg.go

@@ -88,15 +88,9 @@ func (rpc *rpcChat) UserSendMsg(_ context.Context, pb *pbChat.UserSendMsgReq) (*
 				return returnMsg(&replay, pb, m.ResponseErrCode, m.ErrMsg, "", 0)
 			} else {
 				pbData.Content = m.ResponseResult.ModifiedMsg
-				err1 := rpc.sendMsgToKafka(&pbData, pbData.RecvID)
-				err2 := rpc.sendMsgToKafka(&pbData, pbData.SendID)
-				if err1 != nil || err2 != nil {
-					return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
 			}
-				return returnMsg(&replay, pb, 0, "", serverMsgID, pbData.SendTime)
 		}
 	}
-	} else {
 	switch pbData.SessionType {
 	case constant.SingleChatType:
 		err1 := rpc.sendMsgToKafka(&pbData, pbData.RecvID)
@@ -165,7 +159,6 @@ func (rpc *rpcChat) UserSendMsg(_ context.Context, pb *pbChat.UserSendMsgReq) (*
 
 	}
 
-	}
 	return returnMsg(&replay, pb, 203, "unkonwn sessionType", "", 0)
 
 }