2 files changed, 0 insertions, 21 deletions

diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.h b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.h
index a6a5de99cb9..c04199d57ea 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.h
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.h
@@ -156,7 +156,6 @@ public:
     void DeferStartSession(std::shared_ptr<TSingleClusterReadSessionImpl<UseMigrationProtocol>> session);
     void DeferSignalWaiter(TWaiter&& waiter);
     void DeferDestroyDecompressionInfos(std::vector<TDataDecompressionInfoPtr<UseMigrationProtocol>>&& infos);
-    void DeferOnUserRetrievedEvent(TDataDecompressionInfoPtr<UseMigrationProtocol> info, i64 decompressedSize);
 
 private:
     void DoActions();
@@ -167,7 +166,6 @@ private:
     void Reconnect();
     void SignalWaiters();
     void StartSessions();
-    void OnUserRetrievedEvents();
 
 private:
     // Read.
@@ -193,11 +191,6 @@ private:
     std::vector<std::shared_ptr<TSingleClusterReadSessionImpl<UseMigrationProtocol>>> Sessions;
 
     std::vector<TDataDecompressionInfoPtr<UseMigrationProtocol>> DecompressionInfos;
-
-    //
-    // OnUserRetrievedEvent
-    //
-    TUserRetrievedEventsInfoAccumulator<UseMigrationProtocol> UserRetrievedEventsInfo;
 };
 
 template <bool UseMigrationProtocol>
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp
index 4f942b89ca7..22f3088a8b9 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp
@@ -2511,13 +2511,6 @@ void TDeferredActions<UseMigrationProtocol>::DeferDestroyDecompressionInfos(std:
 }
 
 template<bool UseMigrationProtocol>
-void TDeferredActions<UseMigrationProtocol>::DeferOnUserRetrievedEvent(TDataDecompressionInfoPtr<UseMigrationProtocol> parent,
-                                                                       i64 decompressedSize)
-{
-    UserRetrievedEventsInfo.Add(parent, decompressedSize);
-}
-
-template<bool UseMigrationProtocol>
 void TDeferredActions<UseMigrationProtocol>::DoActions() {
     Read();
     StartExecutorTasks();
@@ -2525,7 +2518,6 @@ void TDeferredActions<UseMigrationProtocol>::DoActions() {
     Reconnect();
     SignalWaiters();
     StartSessions();
-    OnUserRetrievedEvents();
 }
 
 template<bool UseMigrationProtocol>
@@ -2577,12 +2569,6 @@ void TDeferredActions<UseMigrationProtocol>::SignalWaiters() {
 }
 
 template<bool UseMigrationProtocol>
-void TDeferredActions<UseMigrationProtocol>::OnUserRetrievedEvents()
-{
-    UserRetrievedEventsInfo.OnUserRetrievedEvent();
-}
-
-template<bool UseMigrationProtocol>
 void TErrorHandler<UseMigrationProtocol>::AbortSession(TASessionClosedEvent<UseMigrationProtocol>&& closeEvent) {
     if (auto session = Session.lock()) {
         session->Abort(std::move(closeEvent));