From a14fd303fcdbd904b8459f22527e8532aae6c488 Mon Sep 17 00:00:00 2001
From: skiffer-git <44203734@qq.com>
Date: Fri, 20 May 2022 14:32:09 +0800
Subject: [PATCH] log

---
 internal/msg_transfer/logic/online_history_msg_handler.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/msg_transfer/logic/online_history_msg_handler.go b/internal/msg_transfer/logic/online_history_msg_handler.go
index b13f02631..7105c08c2 100644
--- a/internal/msg_transfer/logic/online_history_msg_handler.go
+++ b/internal/msg_transfer/logic/online_history_msg_handler.go
@@ -213,6 +213,7 @@ func (och *OnlineHistoryConsumerHandler) MessagesDistributionHandle() {
 			case ConsumerMsgs:
 				consumerMessages := cmd.Value.([]*sarama.ConsumerMessage)
 				//Aggregation map[userid]message list
+				log.Debug(operationID, "consumerMessages len ", len(consumerMessages))
 				for i := 0; i < len(consumerMessages); i++ {
 
 					msgFromMQ := pbMsg.MsgDataToMQ{}