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{}