Fixed diff 5

ydb-platform · Dec 4, 2024 · 547990a · 547990a
1 parent 6a3d76b
commit 547990a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp
@@ -165,7 +165,9 @@ class TTopicSession : public TActorBootstrapped<TTopicSession> {
 
         void UpdateClinetOffset(ui64 offset) override {
             LOG_ROW_DISPATCHER_TRACE("UpdateClinetOffset for " << ReadActorId << ", new offset: " << offset);
-            NextMessageOffset = offset + 1;
+            if (!NextMessageOffset || *NextMessageOffset < offset + 1) {
+                NextMessageOffset = offset + 1;
+            }
         }
 
         // Settings