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

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

diff --git a/internal/msg_transfer/logic/online_history_msg_handler.go b/internal/msg_transfer/logic/online_history_msg_handler.go
index 248e55bd6..6bd344737 100644
--- a/internal/msg_transfer/logic/online_history_msg_handler.go
+++ b/internal/msg_transfer/logic/online_history_msg_handler.go
@@ -378,18 +378,21 @@ func (och *OnlineHistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupS
 	cMsg := make([]*sarama.ConsumerMessage, 500)
 	t := time.NewTicker(time.Duration(500) * time.Millisecond)
 	for msg := range claim.Messages() {
+		operationID := utils.OperationIDGenerator()
 		//och.TriggerCmd(OnlineTopicBusy)
 		cMsg = append(cMsg, msg)
 		select {
 		case <-t.C:
 			if len(cMsg) >= 0 {
 				och.msgDistributionCh <- Cmd2Value{Cmd: ConsumerMsgs, Value: cMsg}
+				log.Debug(operationID, "timer send to msgDistributionCh", och.msgDistributionCh, "len: ", len(cMsg))
 				sess.MarkMessage(msg, "")
 				cMsg = cMsg[0:0]
 			}
 		default:
 			if len(cMsg) >= 500 {
 				och.msgDistributionCh <- Cmd2Value{Cmd: ConsumerMsgs, Value: cMsg}
+				log.Debug(operationID, "500 send to msgDistributionCh", och.msgDistributionCh, "len: ", len(cMsg))
 				sess.MarkMessage(msg, "")
 				cMsg = cMsg[0:0]
 			}