Merge pull request #274 from strideynet/kev-reduce-ingest-cursor-step…

…-back-1-min Reduce ingest cursor step back time to 1 minute
strideynet · Nov 15, 2024 · b8a6474 · b8a6474
2 parents c0ee91a + d3be95b
commit b8a6474
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ingester/ingester.go b/ingester/ingester.go
@@ -131,7 +131,7 @@ func (fi *FirehoseIngester) Start(ctx context.Context) (err error) {
 		initCursor = time.Now().UnixMicro()
 	}
 	// Step back a few minutes to allow recovery
-	initCursor = time.UnixMicro(initCursor).Add(-5 * time.Minute).UnixMicro()
+	initCursor = time.UnixMicro(initCursor).Add(-1 * time.Minute).UnixMicro()
 
 	eg.Go(func() error {
 		for {