fix immediate

nshestakov · nshestakov · commit cdd697c53c82 · 2025-04-18T10:59:20.000Z
diff --git a/ydb/core/persqueue/partition.cpp b/ydb/core/persqueue/partition.cpp
@@ -3015,6 +3015,11 @@ void TPartition::ExecImmediateTx(TTransaction& t)
                                  "incorrect offset range (commit to the future)");
             return;
         }
+
+        if ((i64)operation.GetCommitOffsetsEnd() < pendingUserInfo.Offset && !operation.GetReadSessionId().empty()) {
+            continue; // this is stale request, answer ok for it
+        }
+
         pendingUserInfo.Offset = operation.GetCommitOffsetsEnd();
     }
     CommitWriteOperations(t);

Original file line number	Diff line number	Diff line change
`@@ -3015,6 +3015,11 @@ void TPartition::ExecImmediateTx(TTransaction& t)`
`3015`	`3015`	`"incorrect offset range (commit to the future)");`
`3016`	`3016`	`return;`
`3017`	`3017`	`}`
	`3018`	`+`
	`3019`	`+ if ((i64)operation.GetCommitOffsetsEnd() < pendingUserInfo.Offset && !operation.GetReadSessionId().empty()) {`
	`3020`	`+ continue; // this is stale request, answer ok for it`
	`3021`	`+ }`
	`3022`	`+`
`3018`	`3023`	`pendingUserInfo.Offset = operation.GetCommitOffsetsEnd();`
`3019`	`3024`	`}`
`3020`	`3025`	`CommitWriteOperations(t);`