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

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

diff --git a/internal/msg_transfer/logic/online_history_msg_handler.go b/internal/msg_transfer/logic/online_history_msg_handler.go
index 6bd344737..5e1e5f935 100644
--- a/internal/msg_transfer/logic/online_history_msg_handler.go
+++ b/internal/msg_transfer/logic/online_history_msg_handler.go
@@ -376,7 +376,7 @@ func (och *OnlineHistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupS
 	claim sarama.ConsumerGroupClaim) error { // a instance in the consumer group
 	log.NewDebug("", "online new session msg come", claim.HighWaterMarkOffset(), claim.Topic(), claim.Partition())
 	cMsg := make([]*sarama.ConsumerMessage, 500)
-	t := time.NewTicker(time.Duration(500) * time.Millisecond)
+	t := time.NewTicker(time.Duration(10) * time.Millisecond)
 	for msg := range claim.Messages() {
 		operationID := utils.OperationIDGenerator()
 		//och.TriggerCmd(OnlineTopicBusy)