format useSyncCommits (#1017)

Co-authored-by: wushengyu <[email protected]>
segmentio · Oct 28, 2022 · 029f34c · 029f34c
1 parent 464e3a4
commit 029f34c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/reader.go b/reader.go
@@ -280,7 +280,7 @@ func (r *Reader) commitLoop(ctx context.Context, gen *Generation) {
 		l.Printf("stopped commit for group %s\n", r.config.GroupID)
 	})
 
-	if r.config.CommitInterval == 0 {
+	if r.useSyncCommits() {
 		r.commitLoopImmediate(ctx, gen)
 	} else {
 		r.commitLoopInterval(ctx, gen)