From 547990a91c7629651cff331832ec1510d8454ccd Mon Sep 17 00:00:00 2001
From: Grigoriy Pisarenko <grigoriypisar@ydb.tech>
Date: Wed, 4 Dec 2024 10:24:08 +0000
Subject: [PATCH] Fixed diff 5

---
 ydb/core/fq/libs/row_dispatcher/topic_session.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp
index 710920f04923..bdbcec4268f5 100644
--- 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