[+] commments

ydb/core/persqueue/partition.cpp

@@ -3402,6 +3402,7 @@ void TPartition::ScheduleUpdateAvailableSize(const TActorContext& ctx) {
 void TPartition::ClearOldHead(const ui64 offset, const ui16 partNo, TEvKeyValue::TEvRequest* request) {
     for (auto it = HeadKeys.rbegin(); it != HeadKeys.rend(); ++it) {
         if (it->Key.GetOffset() > offset || it->Key.GetOffset() == offset && it->Key.GetPartNo() >= partNo) {
+            // The repackaged blocks will be deleted after writing.
             DefferedKeysForDeletion.push_back(std::move(it->BlobKeyToken));
 
             Y_UNUSED(request);

ydb/core/persqueue/partition_init.cpp

@@ -575,6 +575,9 @@ void TInitDataRangeStep::FillBlobsMetaData(const NKikimrClient::TKeyValueRespons
     auto& gapSize = Partition()->GapSize;
     auto& bodySize = Partition()->BodySize;
 
+    // If there are multiple keys for a message, then only the key that contains more messages remains.
+    //
+    // Extra keys will be added to the queue for deletion.
     const auto actualKeys = FilterBlobsMetaData(range,
                                                 PartitionId());
 

ydb/core/persqueue/partition_write.cpp

@@ -388,6 +388,7 @@ void TPartition::SyncMemoryStateWithKVState(const TActorContext& ctx) {
         HeadKeys.clear();
     }
 
+    // New blocks have been recorded. You can now delete the keys of the repackaged blocks.
     DefferedKeysForDeletion.clear();
 
     if (NewHeadKey.Size > 0) {