fix for next iterator

fix for next iterator

1 files changed, 1 insertions, 1 deletions

diff --git a/ydb/services/datastreams/datastreams_proxy.cpp b/ydb/services/datastreams/datastreams_proxy.cpp
index 57b427db026..6a5c3f9bc4d 100644
--- a/ydb/services/datastreams/datastreams_proxy.cpp
+++ b/ydb/services/datastreams/datastreams_proxy.cpp
@@ -1496,7 +1496,7 @@ namespace NKikimr::NDataStreams::V1 {
             }
             if (!results.empty()) {
                 auto last = results.rbegin();
-                shardIterator.SetReadTimestamp(last->GetCreateTimestampMS() + 1);
+                shardIterator.SetReadTimestamp(0);
                 shardIterator.SetSequenceNumber(last->GetOffset() + 1);
                 Result.set_millis_behind_latest(TInstant::Now().MilliSeconds() - last->GetWriteTimestampMS());
             } else { // remove else?