Skip to content

Commit 029f34c

Browse files
wsy6543wushengyu
andauthored
format useSyncCommits (#1017)
Co-authored-by: wushengyu <wushengyu@shizhuang-inc.com>
1 parent 464e3a4 commit 029f34c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

reader.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,7 @@ func (r *Reader) commitLoop(ctx context.Context, gen *Generation) {
280280
l.Printf("stopped commit for group %s\n", r.config.GroupID)
281281
})
282282

283-
if r.config.CommitInterval == 0 {
283+
if r.useSyncCommits() {
284284
r.commitLoopImmediate(ctx, gen)
285285
} else {
286286
r.commitLoopInterval(ctx, gen)

0 commit comments

Comments
 (0)