ReceiveMessageOpt

2021-12-07 14:28:07 +08:00
parent 7da98935b9
commit d629874468
5 changed files with 744 additions and 62 deletions
@@ -146,8 +146,8 @@ func SendMsgByWS(m *pbChat.WSToMsgSvrChatMsg) {
 	default:

 	}
-
 }
+
 func sendMsgToKafka(m *pbChat.WSToMsgSvrChatMsg, key string, flag string) {
 	pid, offset, err := producer.SendMessage(m, key)
 	if err != nil {