From eb7ff77461281676ac07b44bd247ca9e8d7dfe05 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Wed, 11 May 2022 19:45:44 +0800 Subject: [PATCH] test --- 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 179de1c79..570de54d9 100644 --- a/internal/msg_transfer/logic/online_history_msg_handler.go +++ b/internal/msg_transfer/logic/online_history_msg_handler.go @@ -141,6 +141,7 @@ func (och *OnlineHistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupS och.msgHandle[msg.Topic](msg.Value, string(msg.Key)) sess.MarkMessage(msg, "") if claim.HighWaterMarkOffset()-msg.Offset <= 1 { + log.Debug("", "online msg consume end", claim.HighWaterMarkOffset(), msg.Offset) och.TriggerCmd(OnlineTopicVacancy) SetOnlineTopicStatus(OnlineTopicVacancy) }