Merge branch 'master' into allow-writer-queue-overflow

Author: rekby

CHANGELOG.md

@@ -1,4 +1,5 @@
 * Allowed overflow queue limit for one goroutine at time for topic writer
+* 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
 	}