From 2eff9cf325113906616e5eb30ab942a1afacf435 Mon Sep 17 00:00:00 2001
From: Nikolay Shestakov <tesseract@ydb.tech>
Date: Thu, 20 Mar 2025 13:14:40 +0000
Subject: [PATCH] fixed possible memory trip

---
 ydb/core/persqueue/read_balancer__balancing.cpp | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/ydb/core/persqueue/read_balancer__balancing.cpp b/ydb/core/persqueue/read_balancer__balancing.cpp
index 02f4bbcee0d5..79218cdff6b9 100644
--- a/ydb/core/persqueue/read_balancer__balancing.cpp
+++ b/ydb/core/persqueue/read_balancer__balancing.cpp
@@ -1079,13 +1079,14 @@ bool TConsumer::ProccessReadingFinished(ui32 partitionId, bool wasInactive, cons
 
 void TConsumer::StartReading(ui32 partitionId, const TActorContext& ctx) {
     if (!GetPartitionInfo(partitionId)) {
-        PQ_LOG_CRIT("start reading for deleted partition " << partitionId);
+        PQ_LOG_NOTICE("Reading of the partition " << partitionId << " was started by " << ConsumerName << " but partition has been deleted.");
         return;
     }
 
     auto* partition = GetPartition(partitionId);
     if (!partition) {
-        PQ_LOG_D("Reading of the partition " << partitionId << " was started by " << ConsumerName << ".");
+        PQ_LOG_NOTICE("Reading of the partition " << partitionId << " was started by " << ConsumerName << " but partition does not exist.");
+        return;
     }
 
     auto wasInactive = partition->IsInactive();