och.redisMessageBatches.OnComplete

[jsn4ke]

OpenIM Server Version

master

Operating System and CPU Architecture

Linux (AMD)

Deployment Method

Source Code Deployment

Bug Description and Steps to Reproduce

1.消息是批处理
2.消息组按key分组
3.och.do 处理客户端上行的消息
4.func (och *OnlineHistoryRedisConsumerHandler) handleMsg 此时网络波动异常

		lastSeq, isNewConversation, userSeqMap, err := och.msgTransferDatabase.BatchInsertChat2Cache(ctx, conversationID, storageMessageList)
		if err != nil && !errors.Is(errs.Unwrap(err), redis.Nil) {
			log.ZWarn(ctx, "batch data insert to redis err", err, "storageMsgList", storageMessageList)
			return
		}

5.b.OnComplete(lastMessage, totalCount)这批消息就异常丢失了

Screenshots Link

No response

[OpenIM-Robot]

Hello! Thank you for filing an issue.

If this is a bug report, please include relevant logs to help us debug the problem.

Join slack 🤖 to connect and communicate with our developers.