From 55907a9a05b8f81ca32311c83b6079a43df0a10d Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Fri, 20 May 2022 21:02:18 +0800
Subject: [PATCH] concurrent consumption of messages

---
 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 5aa94d607..9d0fad271 100644
--- a/internal/msg_transfer/logic/online_history_msg_handler.go
+++ b/internal/msg_transfer/logic/online_history_msg_handler.go
@@ -390,7 +390,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, 0, 500)
-	t := time.NewTicker(time.Duration(10) * time.Millisecond)
+	t := time.NewTicker(time.Duration(100) * time.Millisecond)
 	var triggerID string
 	for msg := range claim.Messages() {
 		//och.TriggerCmd(OnlineTopicBusy)