feat: add update checkpoint sleep

aliyun · May 23, 2023 · aad7ba8 · aad7ba8
1 parent a0c4903
commit aad7ba8
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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