From aad7ba8be5c154888a15d6527c3eeb3c9c8909e2 Mon Sep 17 00:00:00 2001 From: FFish Date: Tue, 23 May 2023 11:50:19 +0000 Subject: [PATCH] feat: add update checkpoint sleep --- consumer/checkpoint_tracker.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/consumer/checkpoint_tracker.go b/consumer/checkpoint_tracker.go index b50f0a65..eca0f5ab 100644 --- a/consumer/checkpoint_tracker.go +++ b/consumer/checkpoint_tracker.go @@ -2,6 +2,7 @@ package consumerLibrary import ( "strings" + "time" sls "github.com/aliyun/aliyun-log-go-sdk" "github.com/go-kit/kit/log" @@ -97,6 +98,7 @@ func (tracker *DefaultCheckPointTracker) flushCheckPoint() error { ) return err } + time.Sleep(100 * time.Millisecond) } tracker.savedCheckPoint = tracker.pendingCheckPoint