Merge pull request #1725 from ydb-platform/ignore-delay-on-sync-commit

Ignore delay before sync commit

Author: rekby

CHANGELOG.md

@@ -1,3 +1,5 @@
+* Removed delay before send commit in sync mode of a topic reader
+
 ## v3.105.2
 * Improved the `ydb.WithSessionPoolSessionUsageLimit` option for allow `time.Duration` as argument type for limit max session time to live since create time 
 

internal/topic/topicreadercommon/committer.go

@@ -167,6 +167,13 @@ func (c *Committer) waitSendTrigger(ctx context.Context) {
 	case <-c.commitLoopSignal:
 	}
 
+	// In sync mode, ignore time lag trigger and send immediately,
+	// because we need to wait for commit ack from the server and can't get
+	// more commit messages until the ack is received.
+	if c.mode == CommitModeSync {
+		return
+	}
+
 	if c.BufferTimeLagTrigger == 0 {
 		return
 	}