hide PublicErrCommitSessionToExpiredSession for async commit mode

rekby · rekby · commit 1acfced48d89 · 2023-01-13T12:35:51.000+03:00
diff --git a/internal/topic/topicreaderinternal/stream_reader_impl.go b/internal/topic/topicreaderinternal/stream_reader_impl.go
@@ -329,6 +329,12 @@ func (r *topicStreamReaderImpl) onPartitionSessionStatusResponseFromBuffer(
 }
 
 func (r *topicStreamReaderImpl) Commit(ctx context.Context, commitRange commitRange) (err error) {
+	defer func() {
+		if errors.Is(err, PublicErrCommitSessionToExpiredSession) && r.cfg.CommitMode == CommitModeAsync {
+			err = nil
+		}
+	}()
+
 	if commitRange.partitionSession == nil {
 		return xerrors.WithStackTrace(errCommitWithNilPartitionSession)
 	}

Original file line number	Diff line number	Diff line change
`@@ -329,6 +329,12 @@ func (r *topicStreamReaderImpl) onPartitionSessionStatusResponseFromBuffer(`
`329`	`329`	`}`
`330`	`330`
`331`	`331`	`func (r *topicStreamReaderImpl) Commit(ctx context.Context, commitRange commitRange) (err error) {`
	`332`	`+ defer func() {`
	`333`	`+ if errors.Is(err, PublicErrCommitSessionToExpiredSession) && r.cfg.CommitMode == CommitModeAsync {`
	`334`	`+ err = nil`
	`335`	`+ }`
	`336`	`+ }()`
	`337`	`+`
`332`	`338`	`if commitRange.partitionSession == nil {`
`333`	`339`	`return xerrors.WithStackTrace(errCommitWithNilPartitionSession)`
`334`	`340`	`}`