2026-03-17T14:16:22.296020Z node 17 :METADATA_PROVIDER WARN: log.cpp:841: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[17:7618228231131695988:2090];send_to=[0:7307199536658146131:7762515];
2026-03-17T14:16:22.296110Z node 17 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:85;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2026-03-17T14:16:22.297555Z node 18 :METADATA_PROVIDER WARN: log.cpp:841: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[18:7618228232656016214:2085];send_to=[0:7307199536658146131:7762515];
2026-03-17T14:16:22.297716Z node 18 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:85;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2026-03-17T14:16:22.298341Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:44: Direct read cache: : Created
2026-03-17T14:16:22.298746Z node 17 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:137: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: LookupError, path: Root/.metadata/script_executions
2026-03-17T14:16:22.299415Z node 18 :PQ_READ_PROXY DEBUG: caching_service.cpp:44: Direct read cache: : Created
2026-03-17T14:16:22.299572Z node 18 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:137: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: LookupError, path: Root/.metadata/script_executions
2026-03-17T14:16:22.316240Z node 17 :IMPORT WARN: schemeshard_import.cpp:466: Table profiles were not loaded
2026-03-17T14:16:22.320429Z node 17 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(18, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2026-03-17T14:16:22.320455Z node 17 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(18, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2026-03-17T14:16:22.325607Z node 17 :HIVE WARN: hive_impl.cpp:797: HIVE#72057594037968897 Handle TEvInterconnect::TEvNodeConnected, NodeId 18 Cookie 18
2026-03-17T14:16:22.325937Z node 17 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(18, (0,0,0,0)) VolatileState: Connecting -> Connected
2026-03-17T14:16:22.331567Z node 17 :NET_CLASSIFIER WARN: net_classifier.cpp:190: distributable config is empty, broken or outdated, will use file: /home/runner/.ya/build/build_root/8zh7/003335/r3tmp/yandexwVRVrn.tmp
2026-03-17T14:16:22.331579Z node 17 :NET_CLASSIFIER WARN: net_classifier.cpp:196: will try to initialize from file: /home/runner/.ya/build/build_root/8zh7/003335/r3tmp/yandexwVRVrn.tmp
2026-03-17T14:16:22.335673Z node 17 :NET_CLASSIFIER WARN: net_classifier.cpp:202: successfully initialized from file: /home/runner/.ya/build/build_root/8zh7/003335/r3tmp/yandexwVRVrn.tmp
2026-03-17T14:16:22.335728Z node 17 :NET_CLASSIFIER ERROR: net_classifier.cpp:228: got bad distributable configuration
2026-03-17T14:16:22.338479Z INFO: TTestServer started on Port 22690 GrpcPort 8051
PQClient connected to localhost:8051
2026-03-17T14:16:22.397541Z node 17 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(17, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2026-03-17T14:16:22.397574Z node 17 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(17, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2026-03-17T14:16:22.399328Z node 17 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(17, (0,0,0,0)) VolatileState: Connecting -> Connected
2026-03-17T14:16:22.399753Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterSubDomain, opId: 281474976720657:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_alter_subdomain.cpp:311)
2026-03-17T14:16:22.419217Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976720659:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:689)
2026-03-17T14:16:22.467890Z node 17 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:137: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: PathErrorUnknown, path: Root/.metadata/script_executions
2026-03-17T14:16:22.599679Z node 18 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:137: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: PathErrorUnknown, path: Root/.metadata/script_executions
2026-03-17T14:16:22.689954Z node 17 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [17:7618228231131697314:2341], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2026-03-17T14:16:22.689984Z node 17 :KQP_WORKLOAD_SERVICE WARN: kqp_workload_service.cpp:352: [WorkloadService] [Service] Failed to fetch pool: default, DatabaseId: /Root, status: NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2026-03-17T14:16:22.690058Z node 17 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [17:7618228231131697337:2345], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2026-03-17T14:16:22.690064Z node 17 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [17:7618228231131697336:2344], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2026-03-17T14:16:22.690071Z node 17 :KQP_WORKLOAD_SERVICE WARN: kqp_workload_service.cpp:352: [WorkloadService] [Service] Failed to fetch pool: default, DatabaseId: /Root, status: NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2026-03-17T14:16:22.690945Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateResourcePool, opId: 281474976720662:3, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_create_resource_pool.cpp:179)
2026-03-17T14:16:22.695196Z node 17 :KQP_WORKLOAD_SERVICE WARN: helpers.h:117: [WorkloadService] [TPoolCreatorActor] ActorId: [17:7618228231131697340:2346], DatabaseId: /Root, PoolId: default, Scheduled retry for error: { <main>: Error: Transaction 281474976720662 completed, doublechecking }
2026-03-17T14:16:22.698471Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976720663:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:689)
2026-03-17T14:16:22.715196Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976720664:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:689)
2026-03-17T14:16:22.735749Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976720665:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:689)
=== Init DC: UPSERT INTO `/Root/PQ/Config/V2/Cluster` (name, balancer, local, enabled, weight) VALUES ("dc1", "localhost", true, true, 1000), ("dc2", "dc2.logbroker.yandex.net", false, true, 1000);
=== CheckClustersList. Subcribe to ClusterTracker from [17:7618228231131697793:3321] 
2026-03-17T14:16:22.778074Z node 17 :TX_PROXY ERROR: schemereq.cpp:631: Actor# [17:7618228231131697794:3322] txid# 281474976720667, issues: { message: "Check failed: path: \'/Root/.metadata/workload_manager/pools/default\', error: path exist, request accepts it (id: [OwnerId: 72057594046644480, LocalPathId: 45], type: EPathTypeResourcePool, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_resource_pool.cpp:92" severity: 1 }
2026-03-17T14:16:23.297950Z node 17 :TX_CONVEYOR ERROR: log.cpp:841: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
2026-03-17T14:16:23.298990Z node 18 :TX_CONVEYOR ERROR: log.cpp:841: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
2026-03-17T14:16:27.296191Z node 17 :METADATA_PROVIDER ERROR: log.cpp:841: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[17:7618228231131695988:2090];send_to=[0:7307199536658146131:7762515];
2026-03-17T14:16:27.296232Z node 17 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:85;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2026-03-17T14:16:27.297702Z node 18 :METADATA_PROVIDER ERROR: log.cpp:841: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[18:7618228232656016214:2085];send_to=[0:7307199536658146131:7762515];
2026-03-17T14:16:27.297747Z node 18 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:85;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
=== CheckClustersList. Ok
PQ Client: create topic: rt3.dc1--topic1 with 3 partitions
CallPersQueueGRPC request to localhost:8051
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic1"
  }
}
2026-03-17T14:16:28.085993Z node 17 :PQ_METACACHE ERROR: msgbus_server_pq_metacache.cpp:384: Handle SchemeCache response: result# { ErrorCount: 1 DatabaseName:  DomainOwnerId: 0 Instant: 2 ResultSet [{ Path: Root/PQ/rt3.dc1--topic1 TableId: [18446744073709551615:18446744073709551615:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: true Status: PathErrorUnknown Kind: KindUnknown DomainInfo <null> }] }
2026-03-17T14:16:28.086046Z node 17 :PERSQUEUE INFO: msgbus_server_persqueue.cpp:1524: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--topic1, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
CallPersQueueGRPC request to localhost:8051
MetaRequest {
  CmdCreateTopic {
    Topic: "rt3.dc1--topic1"
    NumPartitions: 3
    Config {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      Consumers {
        Name: "user"
        ReadFromTimestampsMs: 0
        FormatVersion: 0
        Version: 0
      }
    }
  }
}
CallPersQueueGRPC response:
Status: 129
ProxyErrorCode: 53
SchemeStatus: 1
FlatTxId {
  TxId: 281474976720674
  SchemeShardTabletId: 72057594046644480
  PathId: 49
}
ErrorCode: OK
AddTopic: rt3.dc1--topic1
===Run query:``DECLARE $version as Int64; DECLARE $path AS Utf8; DECLARE $cluster as Utf8; UPSERT INTO `/Root/PQ/Config/V2/Topics` (path, dc) VALUES ($path, $cluster); UPSERT INTO `/Root/PQ/Config/V2/Versions` (name, version) VALUES ("Topics", $version);`` with topic = topic1, dc = dc1
2026-03-17T14:16:28.095486Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:3046: [PQ: 72075186224037892] Handle TEvInterconnect::TEvNodeInfo
2026-03-17T14:16:28.095830Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1669: [72075186224037893][] pipe [17:7618228256901501919:3513] connected; active server actors: 1
2026-03-17T14:16:28.096274Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1521: [72075186224037893][rt3.dc1--topic1] updating configuration. Deleted partitions []. Added partitions [1, 2, 0]
2026-03-17T14:16:28.096452Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:3078: [PQ: 72075186224037892] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2026-03-17T14:16:28.096475Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:765: [72075186224037893][rt3.dc1--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2026-03-17T14:16:28.096508Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:789: [PQ: 72075186224037892] no config, start with empty partitions and default config
2026-03-17T14:16:28.096521Z node 17 :PERSQUEUE NOTICE: pq_impl.cpp:928: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2026-03-17T14:16:28.096528Z node 17 :PERSQUEUE INFO: pq_impl.cpp:614: [PQ: 72075186224037892] doesn't have tx writes info
2026-03-17T14:16:28.096606Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901501918:3512], now have 1 active actors on pipe
2026-03-17T14:16:28.096733Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:145: [72075186224037893][rt3.dc1--topic1] BALANCER INIT DONE for rt3.dc1--topic1: (0, 72075186224037892) (1, 72075186224037892) (2, 72075186224037892) 
2026-03-17T14:16:28.096758Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:3668: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2026-03-17T14:16:28.096862Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [18:7618228258425820748:2387], now have 1 active actors on pipe
2026-03-17T14:16:28.096934Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:399: [72075186224037893][rt3.dc1--topic1] TEvClientConnected TabletId 72075186224037892, NodeId 17, Generation 1
2026-03-17T14:16:28.097358Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:1060: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2026-03-17T14:16:28.101524Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901501997:3573], now have 1 active actors on pipe
2026-03-17T14:16:28.101894Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:1:Initializer] Start initializing step TInitConfigStep
2026-03-17T14:16:28.101910Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:2:Initializer] Start initializing step TInitConfigStep
2026-03-17T14:16:28.101913Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:0:Initializer] Start initializing step TInitConfigStep
2026-03-17T14:16:28.101919Z node 17 :PERSQUEUE DEBUG: partition.cpp:1330: [72075186224037892][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2026-03-17T14:16:28.101922Z node 17 :PERSQUEUE DEBUG: partition.cpp:1330: [72075186224037892][Partition][2][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2026-03-17T14:16:28.101924Z node 17 :PERSQUEUE DEBUG: partition.cpp:1330: [72075186224037892][Partition][1][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2026-03-17T14:16:28.102046Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:1:Initializer] Start initializing step TInitInternalFieldsStep
2026-03-17T14:16:28.102089Z node 17 :PERSQUEUE INFO: partition_init.cpp:1175: [72075186224037892][Partition][1][StateInit] bootstrapping 1 [17:7618228256901502001:2462]
2026-03-17T14:16:28.102656Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:1:Initializer] Start initializing step TInitFieldsStep
2026-03-17T14:16:28.102667Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:66: [rt3.dc1--topic1:1:Initializer] Initializing completed.
2026-03-17T14:16:28.102672Z node 17 :PERSQUEUE INFO: partition.cpp:713: [72075186224037892][Partition][1][StateInit] init complete for topic 'rt3.dc1--topic1' partition 1 generation 1 [17:7618228256901502001:2462]
2026-03-17T14:16:28.102677Z node 17 :PERSQUEUE DEBUG: partition.cpp:733: [72075186224037892][Partition][1][StateInit] SYNC INIT topic rt3.dc1--topic1 partitition 1 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2026-03-17T14:16:28.102683Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][1][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.102948Z node 17 :PERSQUEUE DEBUG: partition.cpp:4532: [72075186224037892][Partition][1][StateIdle] Process pending events. Count 1
2026-03-17T14:16:28.102960Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.102964Z node 17 :PERSQUEUE DEBUG: partition.cpp:2445: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TTransaction[ProposeConfig])
2026-03-17T14:16:28.102972Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.102973Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.102975Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.102976Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.102986Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.102987Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.102989Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.102990Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.102992Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.102998Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2026-03-17T14:16:28.103002Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:114: [72075186224037892][Partition][1][StateIdle] Process MLP pending events. Count 0
2026-03-17T14:16:28.103028Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:2:Initializer] Start initializing step TInitInternalFieldsStep
2026-03-17T14:16:28.103057Z node 17 :PERSQUEUE INFO: partition_init.cpp:1175: [72075186224037892][Partition][2][StateInit] bootstrapping 2 [17:7618228256901502003:2462]
2026-03-17T14:16:28.103408Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:2:Initializer] Start initializing step TInitFieldsStep
2026-03-17T14:16:28.103416Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:66: [rt3.dc1--topic1:2:Initializer] Initializing completed.
2026-03-17T14:16:28.103418Z node 17 :PERSQUEUE INFO: partition.cpp:713: [72075186224037892][Partition][2][StateInit] init complete for topic 'rt3.dc1--topic1' partition 2 generation 1 [17:7618228256901502003:2462]
2026-03-17T14:16:28.103421Z node 17 :PERSQUEUE DEBUG: partition.cpp:733: [72075186224037892][Partition][2][StateInit] SYNC INIT topic rt3.dc1--topic1 partitition 2 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2026-03-17T14:16:28.103424Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][2][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.103591Z node 17 :PERSQUEUE DEBUG: partition.cpp:4532: [72075186224037892][Partition][2][StateIdle] Process pending events. Count 1
2026-03-17T14:16:28.103599Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.103601Z node 17 :PERSQUEUE DEBUG: partition.cpp:2445: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TTransaction[ProposeConfig])
2026-03-17T14:16:28.103605Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.103606Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.103607Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.103608Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.103610Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.103612Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.103613Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.103614Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.103615Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.103618Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2026-03-17T14:16:28.103623Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:114: [72075186224037892][Partition][2][StateIdle] Process MLP pending events. Count 0
2026-03-17T14:16:28.103638Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:0:Initializer] Start initializing step TInitInternalFieldsStep
2026-03-17T14:16:28.103668Z node 17 :PERSQUEUE INFO: partition_init.cpp:1175: [72075186224037892][Partition][0][StateInit] bootstrapping 0 [17:7618228256901502004:2462]
2026-03-17T14:16:28.104014Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:86: [rt3.dc1--topic1:0:Initializer] Start initializing step TInitFieldsStep
2026-03-17T14:16:28.104023Z node 17 :PERSQUEUE DEBUG: partition_init.cpp:66: [rt3.dc1--topic1:0:Initializer] Initializing completed.
2026-03-17T14:16:28.104025Z node 17 :PERSQUEUE INFO: partition.cpp:713: [72075186224037892][Partition][0][StateInit] init complete for topic 'rt3.dc1--topic1' partition 0 generation 1 [17:7618228256901502004:2462]
2026-03-17T14:16:28.104029Z node 17 :PERSQUEUE DEBUG: partition.cpp:733: [72075186224037892][Partition][0][StateInit] SYNC INIT topic rt3.dc1--topic1 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2026-03-17T14:16:28.104031Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][0][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.104180Z node 17 :PERSQUEUE DEBUG: partition.cpp:4532: [72075186224037892][Partition][0][StateIdle] Process pending events. Count 1
2026-03-17T14:16:28.104191Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.104192Z node 17 :PERSQUEUE DEBUG: partition.cpp:2445: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TTransaction[ProposeConfig])
2026-03-17T14:16:28.104197Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104198Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.104199Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104200Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.104203Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.104204Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104206Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.104207Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104208Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.104211Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2026-03-17T14:16:28.104214Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:114: [72075186224037892][Partition][0][StateIdle] Process MLP pending events. Count 0
2026-03-17T14:16:28.104253Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][1][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.104284Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][2][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.104377Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.104399Z node 17 :PERSQUEUE DEBUG: partition.cpp:1439: [72075186224037892][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1773756988150, TxId 281474976720674
2026-03-17T14:16:28.104408Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.104409Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104410Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.104413Z node 17 :PERSQUEUE DEBUG: partition.cpp:2509: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TTransaction[ProposeConfig])
2026-03-17T14:16:28.104449Z node 17 :PERSQUEUE DEBUG: partition.cpp:4010: [72075186224037892][Partition][0][StateIdle] Schedule reply tx done 281474976720674
2026-03-17T14:16:28.104456Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.104457Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][0][StateIdle] Batch completed (1)
2026-03-17T14:16:28.104459Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.104482Z node 17 :PERSQUEUE DEBUG: partition.cpp:1439: [72075186224037892][Partition][1][StateIdle] Handle TEvPQ::TEvTxCommit Step 1773756988150, TxId 281474976720674
2026-03-17T14:16:28.104490Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.104491Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104492Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.104494Z node 17 :PERSQUEUE DEBUG: partition.cpp:2509: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TTransaction[ProposeConfig])
2026-03-17T14:16:28.104505Z node 17 :PERSQUEUE DEBUG: partition.cpp:4010: [72075186224037892][Partition][1][StateIdle] Schedule reply tx done 281474976720674
2026-03-17T14:16:28.104507Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.104509Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][1][StateIdle] Batch completed (1)
2026-03-17T14:16:28.104510Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.104522Z node 17 :PERSQUEUE DEBUG: partition.cpp:1439: [72075186224037892][Partition][2][StateIdle] Handle TEvPQ::TEvTxCommit Step 1773756988150, TxId 281474976720674
2026-03-17T14:16:28.104524Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.104525Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.104526Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.104528Z node 17 :PERSQUEUE DEBUG: partition.cpp:2509: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TTransaction[ProposeConfig])
2026-03-17T14:16:28.104538Z node 17 :PERSQUEUE DEBUG: partition.cpp:4010: [72075186224037892][Partition][2][StateIdle] Schedule reply tx done 281474976720674
2026-03-17T14:16:28.104539Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.104540Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][2][StateIdle] Batch completed (1)
2026-03-17T14:16:28.104542Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.104559Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.104566Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.104570Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.105272Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.105315Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][0][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.105349Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.105365Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.105366Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.105367Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.105369Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.105370Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.105374Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.105378Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][1][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.105396Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][1][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.105407Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][1][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.105408Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.105409Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.105409Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.105410Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.105412Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.105413Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][1][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.105416Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][2][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.105432Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][2][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.105442Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][2][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.105443Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.105444Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.105444Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.105445Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.105446Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.105447Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][2][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.105581Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:400: [PQ: 72075186224037892] Apply new config PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 3 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 0 TopicName: "rt3.dc1--topic1" Version: 0 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--topic1" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Version: 0 Generation: 0 } MonitoringProjectId: ""
2026-03-17T14:16:28.105600Z node 17 :PERSQUEUE NOTICE: pq_impl.cpp:928: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
===Query complete
GetTopicVersionFromPath:  record Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--topic1"
    PathId: 49
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976720674
    CreateStep: 1773756988150
    ParentPathId: 38
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    ChildrenExist: false
  }
  PersQueueGroup {
    Name: "rt3.dc1--topic1"
    PathId: 49
    TotalGroupCount: 3
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      YdbDatabasePath: "/Root"
      Consumers {
        Name: "user"
        ReadFromTimestampsMs: 0
        FormatVersion: 0
        Version: 0
      }
    }
    Partitions {
      PartitionId: 0
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 1
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 2
      TabletId: 72075186224037892
      Status: Active
    }
    AlterVersion: 1
    BalancerTabletID: 72075186224037893
    NextPartitionId: 3
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 1
      PlanResolution: 7
      Coordinators: 72057594046316545
      TimeCastBucketsPerMediator: 2
      Mediators: 72057594046382081
    }
    DomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    PathsInside: 48
    PathsLimit: 10000
    ShardsInside: 6
    ShardsLimit: 200000
    ResourcesDomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    DiskSpaceUsage {
      Tables {
        TotalSize: 0
        DataSize: 0
        IndexSize: 0
      }
      Topics {
        ReserveSize: 0
        AccountSize: 0
        DataSize: 0
        UsedReserveSize: 0
      }
    }
    PQPartitionsInside: 3
    PQPartitionsLimit: 1000000
    SchemeLimits {
      MaxDepth: 32
      MaxPaths: 10000
      MaxChildrenInDir: 100000
      MaxAclBytesSize: 10240
      MaxTableColumns: 200
      MaxTableColumnNameLength: 255
      MaxTableKeyColumns: 30
      MaxTableIndices: 20
      MaxShards: 200000
      MaxShardsInPath: 35000
      MaxConsistentCopyTargets: 10000
      MaxPathElementLength: 255
      ExtraPathSymbolsAllowed: "!\"#$%&\'()*+,-.:;<=>?@[\\]^_`{|}~"
      MaxPQPartitions: 1000000
      MaxTableCdcStreams: 5
      MaxExports: 10
      MaxImports: 10
      MaxColumnTableColumns: 10000
    }
  }
}
Path: "/Root/PQ/rt3.dc1--topic1"
 name rt3.dc1--topic1 version1
CallPersQueueGRPC request to localhost:8051
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic1"
  }
}
2026-03-17T14:16:28.114196Z node 17 :PERSQUEUE INFO: msgbus_server_persqueue.cpp:1524: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetTopicMetadataResult {
    TopicInfo {
      Topic: "rt3.dc1--topic1"
      NumPartitions: 3
      Config {
        PartitionConfig {
          LifetimeSeconds: 86400
          LowWatermark: 8388608
          SourceIdLifetimeSeconds: 86400
          WriteSpeedInBytesPerSecond: 20000000
          BurstSize: 20000000
          SourceIdMaxCounts: 6000000
        }
        Version: 1
        LocalDC: true
        Codecs {
          Ids: 0
          Ids: 1
          Ids: 2
          Codecs: "raw"
          Codecs: "gzip"
          Codecs: "lzop"
        }
        TopicPath: "/Root/PQ/rt3.dc1--topic1"
        YdbDatabasePath: "/Root"
        Consumers {
          Name: "user"
          ReadFromTimestampsMs: 0
          FormatVersion: 0
          Version: 0
        }
      }
      ErrorCode: OK
    }
  }
}
=== Topic created, have version: 1
2026-03-17T14:16:28.117196Z node 17 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:140: new alter topic request
2026-03-17T14:16:28.117880Z node 17 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterPersQueueGroup, opId: 281474976720676:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at ydb/core/tx/schemeshard/schemeshard__operation_alter_pq.cpp:308)
2026-03-17T14:16:28.119626Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1521: [72075186224037893][rt3.dc1--topic1] updating configuration. Deleted partitions []. Added partitions []
2026-03-17T14:16:28.119608Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:3668: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2026-03-17T14:16:28.120306Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:1060: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2026-03-17T14:16:28.121998Z node 17 :PERSQUEUE DEBUG: partition.cpp:1295: [72075186224037892][Partition][0][StateIdle] Handle TEvPQ::TEvProposePartitionConfig Step 1773756988171, TxId 281474976720676
2026-03-17T14:16:28.122014Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.122020Z node 17 :PERSQUEUE DEBUG: partition.cpp:2445: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TTransaction[ProposeConfig])
2026-03-17T14:16:28.122030Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122032Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.122036Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122038Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.122050Z node 17 :PERSQUEUE DEBUG: partition.cpp:1295: [72075186224037892][Partition][2][StateIdle] Handle TEvPQ::TEvProposePartitionConfig Step 1773756988171, TxId 281474976720676
2026-03-17T14:16:28.122053Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.122056Z node 17 :PERSQUEUE DEBUG: partition.cpp:2445: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TTransaction[ProposeConfig])
2026-03-17T14:16:28.122061Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122065Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.122067Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122070Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.122077Z node 17 :PERSQUEUE DEBUG: partition.cpp:1295: [72075186224037892][Partition][1][StateIdle] Handle TEvPQ::TEvProposePartitionConfig Step 1773756988171, TxId 281474976720676
2026-03-17T14:16:28.122082Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.122086Z node 17 :PERSQUEUE DEBUG: partition.cpp:2445: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TTransaction[ProposeConfig])
2026-03-17T14:16:28.122091Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122093Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.122096Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122098Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.122195Z node 17 :PERSQUEUE DEBUG: partition.cpp:1439: [72075186224037892][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1773756988171, TxId 281474976720676
2026-03-17T14:16:28.122220Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.122222Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122223Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.122227Z node 17 :PERSQUEUE DEBUG: partition.cpp:2509: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TTransaction[ProposeConfig])
2026-03-17T14:16:28.122275Z node 17 :PERSQUEUE DEBUG: partition.cpp:3896: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user debug reinit with generation 2 done
2026-03-17T14:16:28.122286Z node 17 :PERSQUEUE DEBUG: partition.cpp:4010: [72075186224037892][Partition][0][StateIdle] Schedule reply tx done 281474976720676
2026-03-17T14:16:28.122288Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.122291Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][0][StateIdle] Batch completed (1)
2026-03-17T14:16:28.122294Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.122336Z node 17 :PERSQUEUE DEBUG: partition.cpp:1439: [72075186224037892][Partition][1][StateIdle] Handle TEvPQ::TEvTxCommit Step 1773756988171, TxId 281474976720676
2026-03-17T14:16:28.122345Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.122347Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122349Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.122353Z node 17 :PERSQUEUE DEBUG: partition.cpp:2509: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TTransaction[ProposeConfig])
2026-03-17T14:16:28.122371Z node 17 :PERSQUEUE DEBUG: partition.cpp:3896: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user debug reinit with generation 2 done
2026-03-17T14:16:28.122378Z node 17 :PERSQUEUE DEBUG: partition.cpp:4010: [72075186224037892][Partition][1][StateIdle] Schedule reply tx done 281474976720676
2026-03-17T14:16:28.122380Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.122381Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][1][StateIdle] Batch completed (1)
2026-03-17T14:16:28.122384Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.122401Z node 17 :PERSQUEUE DEBUG: partition.cpp:1439: [72075186224037892][Partition][2][StateIdle] Handle TEvPQ::TEvTxCommit Step 1773756988171, TxId 281474976720676
2026-03-17T14:16:28.122409Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.122410Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.122412Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.122414Z node 17 :PERSQUEUE DEBUG: partition.cpp:2509: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TTransaction[ProposeConfig])
2026-03-17T14:16:28.122426Z node 17 :PERSQUEUE DEBUG: partition.cpp:3896: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user debug reinit with generation 2 done
2026-03-17T14:16:28.122428Z node 17 :PERSQUEUE DEBUG: partition.cpp:4010: [72075186224037892][Partition][2][StateIdle] Schedule reply tx done 281474976720676
2026-03-17T14:16:28.122429Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.122430Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][2][StateIdle] Batch completed (1)
2026-03-17T14:16:28.122432Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.122451Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.122459Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.122469Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.123108Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.123149Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][0][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.123483Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.123497Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.123498Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.123500Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.123502Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.123503Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.123507Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.123512Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][1][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.123531Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][1][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.123696Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][1][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.123704Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.123705Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.123706Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.123707Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.123708Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.123709Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][1][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.123713Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][2][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.123729Z node 17 :PERSQUEUE DEBUG: partition_mlp.cpp:151: [72075186224037892][Partition][2][StateIdle] Initializing MLP Consumers: 0
2026-03-17T14:16:28.123929Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][2][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.123937Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.123938Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.123951Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.123953Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.123954Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.123956Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][2][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.124081Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:400: [PQ: 72075186224037892] Apply new config PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 3 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 0 TopicName: "rt3.dc1--topic1" Version: 2 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--topic1" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Type: CONSUMER_TYPE_STREAMING } Consumers { Name: "debug" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 2 Type: CONSUMER_TYPE_STREAMING } MonitoringProjectId: ""
2026-03-17T14:16:28.124090Z node 17 :PERSQUEUE NOTICE: pq_impl.cpp:928: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2026-03-17T14:16:28.128026Z node 17 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:107: new grpc connection
2026-03-17T14:16:28.128044Z node 17 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:141: new session created cookie 1
2026-03-17T14:16:28.128209Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 1 sessionId:  grpc read done: success: 1 data: init_request { path: "rt3.dc1--topic1" message_group_id: "" }
2026-03-17T14:16:28.128255Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:460: session request cookie: 1 path: "rt3.dc1--topic1" message_group_id: "" from ipv6:[::1]:36988
2026-03-17T14:16:28.128261Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:462: session request cookie: 1. Disable deduplication for empty producer id
2026-03-17T14:16:28.128266Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:1542: write session:  cookie=1 sessionId= userAgent="topic server" ip=ipv6:[::1]:36988 proto=topic user=- topic=Topic rt3.dc1--topic1 in dc dc1 durationSec=0
2026-03-17T14:16:28.128269Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:584: init check schema
2026-03-17T14:16:28.128682Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:645: session v1 cookie: 1 sessionId:  describe result for acl check
2026-03-17T14:16:28.128717Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:62: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint32; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `/Root/PQ/SourceIdMeta2` WHERE Hash == $Hash AND Topic == $Topic AND SourceId == $SourceId;
2026-03-17T14:16:28.128718Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:63: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;DECLARE $SeqNo AS Uint64;
UPSERT INTO `/Root/PQ/SourceIdMeta2` (Hash, Topic, SourceId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2026-03-17T14:16:28.128720Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:64: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `/Root/PQ/SourceIdMeta2` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND SourceId = $SourceId AND Partition = $Partition;
2026-03-17T14:16:28.128725Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:67: TPartitionChooser [17:7618228256901502143:2478] (SourceId=, PreferedPartition=(NULL)) RequestPQRB
2026-03-17T14:16:28.128884Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1669: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502144:2478] connected; active server actors: 1
2026-03-17T14:16:28.128992Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:80: TPartitionChooser [17:7618228256901502143:2478] (SourceId=, PreferedPartition=(NULL)) Received partition 0 from PQRB for SourceId=
2026-03-17T14:16:28.129003Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:305: TPartitionChooser [17:7618228256901502143:2478] (SourceId=, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=0
2026-03-17T14:16:28.129016Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:707: ProceedPartition. session cookie: 1 sessionId:  partition: 0 expectedGeneration: (NULL)
2026-03-17T14:16:28.129054Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1673: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502144:2478] disconnected.
2026-03-17T14:16:28.129063Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1684: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502144:2478] disconnected; active server actors: 1
2026-03-17T14:16:28.129067Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1709: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502144:2478] disconnected no session
2026-03-17T14:16:28.129145Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:839: TPartitionWriter 72075186224037892 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037892, NodeId 17, Generation: 1
2026-03-17T14:16:28.129162Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901502147:2478], now have 1 active actors on pipe
2026-03-17T14:16:28.129172Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.129178Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 0
2026-03-17T14:16:28.129207Z node 17 :PERSQUEUE INFO: ownerinfo.cpp:30: new Cookie f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0 generated for partition 0 topic 'rt3.dc1--topic1' owner f8c536e5-97ba97ea-fc91bf1f-34812e65
2026-03-17T14:16:28.129223Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.129226Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.129231Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.129233Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.129237Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.129246Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.129253Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][0][StateIdle] Batch completed (1)
2026-03-17T14:16:28.129255Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.129270Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:37: [72075186224037892][Partition][0][StateIdle] TPartition::ReplyOwnerOk. Partition: 0
2026-03-17T14:16:28.129288Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.129353Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.129364Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 0
2026-03-17T14:16:28.129387Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.129427Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:884: session inited cookie: 1 partition: 0 MaxSeqNo: 0 sessionId: f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0
2026-03-17T14:16:28.130218Z node 17 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:107: new grpc connection
2026-03-17T14:16:28.130230Z node 17 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:141: new session created cookie 2
2026-03-17T14:16:28.130344Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 1 sessionId: f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0 grpc read done: success: 1 data:  write_request[data omitted]
2026-03-17T14:16:28.130386Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 2 sessionId:  grpc read done: success: 1 data: init_request { path: "rt3.dc1--topic1" message_group_id: "" }
2026-03-17T14:16:28.130419Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=0) Received event: NKikimr::NPQ::TEvPartitionWriter::TEvWriteRequest
2026-03-17T14:16:28.130426Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:460: session request cookie: 2 path: "rt3.dc1--topic1" message_group_id: "" from ipv6:[::1]:36988
2026-03-17T14:16:28.130428Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:462: session request cookie: 2. Disable deduplication for empty producer id
2026-03-17T14:16:28.130441Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:1542: write session:  cookie=2 sessionId= userAgent="topic server" ip=ipv6:[::1]:36988 proto=topic user=- topic=Topic rt3.dc1--topic1 in dc dc1 durationSec=0
2026-03-17T14:16:28.130445Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:584: init check schema
2026-03-17T14:16:28.130469Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.130479Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 0
2026-03-17T14:16:28.130500Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 1
2026-03-17T14:16:28.130524Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=0) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.130558Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.130567Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 0
2026-03-17T14:16:28.130658Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 0 SourceId: '' SeqNo: 1 partNo : 0 messageNo: 1 size 99 offset: -1
2026-03-17T14:16:28.130669Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 0 SourceId: '' SeqNo: 2 partNo : 0 messageNo: 1 size 99 offset: -1
2026-03-17T14:16:28.130674Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 0 SourceId: '' SeqNo: 3 partNo : 0 messageNo: 1 size 99 offset: -1
2026-03-17T14:16:28.130684Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:636: [72075186224037892][Partition][0][StateIdle] Received TPartition::TEvWrite
2026-03-17T14:16:28.130699Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.130705Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.130712Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.130714Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.130718Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 3, PendingWrites: 0
2026-03-17T14:16:28.130719Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.130722Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.130758Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 part blob processing sourceId '' seqNo 1 partNo 0
2026-03-17T14:16:28.130805Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 part blob complete sourceId '' seqNo 1 partNo 0 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 166 count 1 nextOffset 1 batches 1
2026-03-17T14:16:28.130816Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.130819Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 part blob processing sourceId '' seqNo 2 partNo 0
2026-03-17T14:16:28.130822Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 part blob complete sourceId '' seqNo 2 partNo 0 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 300 count 2 nextOffset 2 batches 1
2026-03-17T14:16:28.130825Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.130826Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 part blob processing sourceId '' seqNo 3 partNo 0
2026-03-17T14:16:28.130827Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:645: session v1 cookie: 2 sessionId:  describe result for acl check
2026-03-17T14:16:28.130830Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 part blob complete sourceId '' seqNo 3 partNo 0 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 434 count 3 nextOffset 3 batches 1
2026-03-17T14:16:28.130832Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 3
2026-03-17T14:16:28.130834Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][0][StateIdle] Batch completed (3)
2026-03-17T14:16:28.130836Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.130856Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:62: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint32; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `/Root/PQ/SourceIdMeta2` WHERE Hash == $Hash AND Topic == $Topic AND SourceId == $SourceId;
2026-03-17T14:16:28.130868Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:63: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;DECLARE $SeqNo AS Uint64;
UPSERT INTO `/Root/PQ/SourceIdMeta2` (Hash, Topic, SourceId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2026-03-17T14:16:28.130871Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:64: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `/Root/PQ/SourceIdMeta2` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND SourceId = $SourceId AND Partition = $Partition;
2026-03-17T14:16:28.130873Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1711: [72075186224037892][Partition][0][StateIdle] Add new write blob: topic 'rt3.dc1--topic1' partition 0 compactOffset 0,3 HeadOffset 0 endOffset 0 curOffset 3 d0000000000_00000000000000000000_00000_0000000003_00000? size 409 WTime 1773756988130
2026-03-17T14:16:28.130876Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:67: TPartitionChooser [17:7618228256901502151:2480] (SourceId=, PreferedPartition=(NULL)) RequestPQRB
2026-03-17T14:16:28.130899Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.130912Z node 17 :PERSQUEUE DEBUG: read.h:313: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough blob. Partition 0 offset 0 partNo 0 count 3 size 409
2026-03-17T14:16:28.131009Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1669: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502152:2480] connected; active server actors: 1
2026-03-17T14:16:28.131136Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:80: TPartitionChooser [17:7618228256901502151:2480] (SourceId=, PreferedPartition=(NULL)) Received partition 1 from PQRB for SourceId=
2026-03-17T14:16:28.131149Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:305: TPartitionChooser [17:7618228256901502151:2480] (SourceId=, PreferedPartition=(NULL)) ReplyResult: Partition=1, SeqNo=0
2026-03-17T14:16:28.131164Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:707: ProceedPartition. session cookie: 2 sessionId:  partition: 1 expectedGeneration: (NULL)
2026-03-17T14:16:28.131202Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1673: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502152:2480] disconnected.
2026-03-17T14:16:28.131215Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1684: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502152:2480] disconnected; active server actors: 1
2026-03-17T14:16:28.131218Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1709: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502152:2480] disconnected no session
2026-03-17T14:16:28.131256Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:839: TPartitionWriter 72075186224037892 (partition=1) TEvClientConnected Status OK, TabletId: 72075186224037892, NodeId 17, Generation: 1
2026-03-17T14:16:28.131267Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901502158:2480], now have 1 active actors on pipe
2026-03-17T14:16:28.131272Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.131275Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.131292Z node 17 :PERSQUEUE INFO: ownerinfo.cpp:30: new Cookie d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 generated for partition 1 topic 'rt3.dc1--topic1' owner d007172b-e4e79599-c62f9cbc-9ffbe5b3
2026-03-17T14:16:28.131295Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.131297Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.131299Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.131301Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.131303Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.131308Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.131310Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][1][StateIdle] Batch completed (1)
2026-03-17T14:16:28.131312Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.131319Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:37: [72075186224037892][Partition][1][StateIdle] TPartition::ReplyOwnerOk. Partition: 1
2026-03-17T14:16:28.131329Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.131372Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.131384Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.131398Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.131426Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:884: session inited cookie: 2 partition: 1 MaxSeqNo: 0 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0
2026-03-17T14:16:28.131702Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:311: Caching head blob in L1. Partition 0 offset 0 count 3 size 409 actorID [17:7618228256901501957:2462]
2026-03-17T14:16:28.131723Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.131744Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 297 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.131746Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:129: PQ Cache (L2). Adding blob. Tablet '72075186224037892' partition 0 offset 0 partno 0 count 3 parts 0 suffix '63' size 409
2026-03-17T14:16:28.131759Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][0][StateIdle] TPartition::ReplyWrite. Partition: 0
2026-03-17T14:16:28.131766Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][0][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 0, SeqNo: 1, partNo: 0, Offset: 0 is stored on disk
2026-03-17T14:16:28.131770Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][0][StateIdle] TPartition::ReplyWrite. Partition: 0
2026-03-17T14:16:28.131773Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][0][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 0, SeqNo: 2, partNo: 0, Offset: 1 is stored on disk
2026-03-17T14:16:28.131775Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][0][StateIdle] TPartition::ReplyWrite. Partition: 0
2026-03-17T14:16:28.131778Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][0][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 0, SeqNo: 3, partNo: 0, Offset: 2 is stored on disk
2026-03-17T14:16:28.131797Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2026-03-17T14:16:28.131807Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:976: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user user send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 0
2026-03-17T14:16:28.131810Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user debug readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 2
2026-03-17T14:16:28.131812Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.131814Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.131815Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.131817Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.131821Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.131826Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.131834Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 0 messageNo: 1  requestId: <none> cookie: 1
2026-03-17T14:16:28.131880Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][0][StateIdle] read cookie 3 Topic 'rt3.dc1--topic1' partition 0 user user offset 0 partno 0 count 1 size 1024000 endOffset 3 max time lag 0ms effective offset 0
2026-03-17T14:16:28.131890Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=0) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.131896Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][0][StateIdle] read cookie 3 added 1 blobs, size 409 count 3 last offset 0, current partition end offset: 3
2026-03-17T14:16:28.131898Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][0][StateIdle] Reading cookie 3. Send blob request.
2026-03-17T14:16:28.131906Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 0 offset 0 partno 0 count 3 parts_count 0 source 1 size 409 accessed 0 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.131952Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 3. All 1 blobs are from cache.
2026-03-17T14:16:28.131966Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.131969Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 0 offset 0 partno 0 count 3 parts 0 suffix '63'
2026-03-17T14:16:28.131976Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 3 count 3 size 389 from pos 0 cbcount 3
2026-03-17T14:16:28.131991Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1026: Topic 'rt3.dc1--topic1' partition 0 user user readTimeStamp done, result 1773756988130 queuesize 1 startOffset 0
2026-03-17T14:16:28.132000Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user debug readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 2
2026-03-17T14:16:28.132002Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:976: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user debug send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 2
2026-03-17T14:16:28.132013Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][0][StateIdle] read cookie 4 Topic 'rt3.dc1--topic1' partition 0 user debug offset 0 partno 0 count 1 size 1024000 endOffset 3 max time lag 0ms effective offset 0
2026-03-17T14:16:28.132025Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][0][StateIdle] read cookie 4 added 1 blobs, size 409 count 3 last offset 0, current partition end offset: 3
2026-03-17T14:16:28.132026Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][0][StateIdle] Reading cookie 4. Send blob request.
2026-03-17T14:16:28.132030Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 0 offset 0 partno 0 count 3 parts_count 0 source 1 size 409 accessed 1 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.132036Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 4. All 1 blobs are from cache.
2026-03-17T14:16:28.132039Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.132042Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 3 count 3 size 389 from pos 0 cbcount 3
2026-03-17T14:16:28.132045Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 0 offset 0 partno 0 count 3 parts 0 suffix '63'
2026-03-17T14:16:28.132047Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1026: Topic 'rt3.dc1--topic1' partition 0 user debug readTimeStamp done, result 1773756988130 queuesize 0 startOffset 0
2026-03-17T14:16:28.132059Z node 17 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:107: new grpc connection
2026-03-17T14:16:28.132066Z node 17 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:141: new session created cookie 3
2026-03-17T14:16:28.132150Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 2 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 grpc read done: success: 1 data:  write_request[data omitted]
2026-03-17T14:16:28.132186Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NKikimr::NPQ::TEvPartitionWriter::TEvWriteRequest
2026-03-17T14:16:28.132210Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.132218Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.132228Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 0  requestId: <none> cookie: 1
2026-03-17T14:16:28.132237Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.132256Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.132258Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.132271Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 1 SourceId: '' SeqNo: 1 partNo : 0 messageNo: 1 size 99 offset: -1
2026-03-17T14:16:28.132276Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:636: [72075186224037892][Partition][1][StateIdle] Received TPartition::TEvWrite
2026-03-17T14:16:28.132285Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.132287Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.132292Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.132296Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.132299Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.132313Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 part blob processing sourceId '' seqNo 1 partNo 0
2026-03-17T14:16:28.132335Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 2 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 grpc read done: success: 1 data:  write_request[data omitted]
2026-03-17T14:16:28.132353Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 part blob complete sourceId '' seqNo 1 partNo 0 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 166 count 1 nextOffset 1 batches 1
2026-03-17T14:16:28.132356Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.132358Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][1][StateIdle] Batch completed (1)
2026-03-17T14:16:28.132360Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.132381Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NKikimr::NPQ::TEvPartitionWriter::TEvWriteRequest
2026-03-17T14:16:28.132388Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1711: [72075186224037892][Partition][1][StateIdle] Add new write blob: topic 'rt3.dc1--topic1' partition 1 compactOffset 0,1 HeadOffset 0 endOffset 0 curOffset 1 d0000000001_00000000000000000000_00000_0000000001_00000? size 154 WTime 1773756988132
2026-03-17T14:16:28.132405Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.132418Z node 17 :PERSQUEUE DEBUG: read.h:313: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough blob. Partition 1 offset 0 partNo 0 count 1 size 154
2026-03-17T14:16:28.132423Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.132428Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 3 sessionId:  grpc read done: success: 1 data: init_request { path: "rt3.dc1--topic1" message_group_id: "" }
2026-03-17T14:16:28.132429Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.132447Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:460: session request cookie: 3 path: "rt3.dc1--topic1" message_group_id: "" from ipv6:[::1]:36988
2026-03-17T14:16:28.132455Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:462: session request cookie: 3. Disable deduplication for empty producer id
2026-03-17T14:16:28.132461Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:1542: write session:  cookie=3 sessionId= userAgent="topic server" ip=ipv6:[::1]:36988 proto=topic user=- topic=Topic rt3.dc1--topic1 in dc dc1 durationSec=0
2026-03-17T14:16:28.132464Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:584: init check schema
2026-03-17T14:16:28.132467Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 2  requestId: <none> cookie: 2
2026-03-17T14:16:28.132484Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.132548Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.132555Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.132563Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 1 SourceId: '' SeqNo: 2 partNo : 0 messageNo: 3 size 99 offset: -1
2026-03-17T14:16:28.132567Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 1 SourceId: '' SeqNo: 3 partNo : 0 messageNo: 3 size 99 offset: -1
2026-03-17T14:16:28.132571Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:636: [72075186224037892][Partition][1][StateIdle] Received TPartition::TEvWrite
2026-03-17T14:16:28.132577Z node 17 :PERSQUEUE DEBUG: partition.cpp:2334: [72075186224037892][Partition][1][StateIdle] Writing. Can't process user action and tx events
2026-03-17T14:16:28.132837Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:645: session v1 cookie: 3 sessionId:  describe result for acl check
2026-03-17T14:16:28.132866Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:62: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint32; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `/Root/PQ/SourceIdMeta2` WHERE Hash == $Hash AND Topic == $Topic AND SourceId == $SourceId;
2026-03-17T14:16:28.132876Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:63: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;DECLARE $SeqNo AS Uint64;
UPSERT INTO `/Root/PQ/SourceIdMeta2` (Hash, Topic, SourceId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2026-03-17T14:16:28.132878Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:64: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `/Root/PQ/SourceIdMeta2` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND SourceId = $SourceId AND Partition = $Partition;
2026-03-17T14:16:28.132882Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:67: TPartitionChooser [17:7618228256901502167:2482] (SourceId=, PreferedPartition=(NULL)) RequestPQRB
2026-03-17T14:16:28.132950Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:311: Caching head blob in L1. Partition 1 offset 0 count 1 size 154 actorID [17:7618228256901501957:2462]
2026-03-17T14:16:28.132971Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][1][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.132981Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:129: PQ Cache (L2). Adding blob. Tablet '72075186224037892' partition 1 offset 0 partno 0 count 1 parts 0 suffix '63' size 154
2026-03-17T14:16:28.132988Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][1][StateIdle] TPartition::HandleWriteResponse writeNewSize# 99 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.132994Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][1][StateIdle] TPartition::ReplyWrite. Partition: 1
2026-03-17T14:16:28.133001Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][1][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 1, SeqNo: 1, partNo: 0, Offset: 0 is stored on disk
2026-03-17T14:16:28.132998Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1669: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502168:2482] connected; active server actors: 1
2026-03-17T14:16:28.133020Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2026-03-17T14:16:28.133031Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:976: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user user send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 0
2026-03-17T14:16:28.133036Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user debug readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 2
2026-03-17T14:16:28.133040Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.133042Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.133047Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.133050Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 2, PendingWrites: 0
2026-03-17T14:16:28.133053Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.133056Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.133069Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 part blob processing sourceId '' seqNo 2 partNo 0
2026-03-17T14:16:28.133097Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 part blob complete sourceId '' seqNo 2 partNo 0 FormedBlobsCount 0 NewHead: Offset 1 PartNo 0 PackedSize 166 count 1 nextOffset 2 batches 1
2026-03-17T14:16:28.133107Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.133111Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 part blob processing sourceId '' seqNo 3 partNo 0
2026-03-17T14:16:28.133117Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 part blob complete sourceId '' seqNo 3 partNo 0 FormedBlobsCount 0 NewHead: Offset 1 PartNo 0 PackedSize 300 count 2 nextOffset 3 batches 1
2026-03-17T14:16:28.133123Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 2
2026-03-17T14:16:28.133125Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][1][StateIdle] Batch completed (2)
2026-03-17T14:16:28.133128Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.133139Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:80: TPartitionChooser [17:7618228256901502167:2482] (SourceId=, PreferedPartition=(NULL)) Received partition 2 from PQRB for SourceId=
2026-03-17T14:16:28.133148Z node 17 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:305: TPartitionChooser [17:7618228256901502167:2482] (SourceId=, PreferedPartition=(NULL)) ReplyResult: Partition=2, SeqNo=0
2026-03-17T14:16:28.133162Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:707: ProceedPartition. session cookie: 3 sessionId:  partition: 2 expectedGeneration: (NULL)
2026-03-17T14:16:28.133165Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1711: [72075186224037892][Partition][1][StateIdle] Add new write blob: topic 'rt3.dc1--topic1' partition 1 compactOffset 1,2 HeadOffset 1 endOffset 1 curOffset 3 d0000000001_00000000000000000001_00000_0000000002_00000? size 288 WTime 1773756988132
2026-03-17T14:16:28.133185Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][1][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.133190Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1673: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502168:2482] disconnected.
2026-03-17T14:16:28.133200Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 1  requestId: <none> cookie: 1
2026-03-17T14:16:28.133207Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1684: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502168:2482] disconnected; active server actors: 1
2026-03-17T14:16:28.133209Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1709: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502168:2482] disconnected no session
2026-03-17T14:16:28.133227Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.133236Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.133242Z node 17 :PERSQUEUE DEBUG: read.h:313: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough blob. Partition 1 offset 1 partNo 0 count 2 size 288
2026-03-17T14:16:28.133281Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][1][StateIdle] read cookie 3 Topic 'rt3.dc1--topic1' partition 1 user user offset 0 partno 0 count 1 size 1024000 endOffset 1 max time lag 0ms effective offset 0
2026-03-17T14:16:28.133302Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][1][StateIdle] read cookie 3 added 1 blobs, size 154 count 1 last offset 0, current partition end offset: 1
2026-03-17T14:16:28.133309Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][1][StateIdle] Reading cookie 3. Send blob request.
2026-03-17T14:16:28.133322Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 1 offset 0 partno 0 count 1 parts_count 0 source 1 size 154 accessed 0 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.133341Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 3. All 1 blobs are from cache.
2026-03-17T14:16:28.133344Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 1 offset 0 partno 0 count 1 parts 0 suffix '63'
2026-03-17T14:16:28.133353Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:839: TPartitionWriter 72075186224037892 (partition=2) TEvClientConnected Status OK, TabletId: 72075186224037892, NodeId 17, Generation: 1
2026-03-17T14:16:28.133424Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901502171:2482], now have 1 active actors on pipe
2026-03-17T14:16:28.133436Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.133443Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 1 count 1 size 134 from pos 0 cbcount 1
2026-03-17T14:16:28.133455Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.133464Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.133473Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1026: Topic 'rt3.dc1--topic1' partition 1 user user readTimeStamp done, result 1773756988132 queuesize 1 startOffset 0
2026-03-17T14:16:28.133482Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user debug readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 2
2026-03-17T14:16:28.133485Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:976: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user debug send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 2
2026-03-17T14:16:28.133502Z node 17 :PERSQUEUE INFO: ownerinfo.cpp:30: new Cookie 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 generated for partition 2 topic 'rt3.dc1--topic1' owner 7f73289e-b235a64e-e3c1c5c8-259157e7
2026-03-17T14:16:28.133513Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.133515Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.133518Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.133521Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.133524Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.133528Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.133531Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][2][StateIdle] Batch completed (1)
2026-03-17T14:16:28.133535Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.133542Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:37: [72075186224037892][Partition][2][StateIdle] TPartition::ReplyOwnerOk. Partition: 2
2026-03-17T14:16:28.133551Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.133574Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][1][StateIdle] read cookie 4 Topic 'rt3.dc1--topic1' partition 1 user debug offset 0 partno 0 count 1 size 1024000 endOffset 1 max time lag 0ms effective offset 0
2026-03-17T14:16:28.133592Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][1][StateIdle] read cookie 4 added 1 blobs, size 154 count 1 last offset 0, current partition end offset: 1
2026-03-17T14:16:28.133599Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][1][StateIdle] Reading cookie 4. Send blob request.
2026-03-17T14:16:28.133603Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.133606Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.133614Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 1 offset 0 partno 0 count 1 parts_count 0 source 1 size 154 accessed 1 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.133627Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 4. All 1 blobs are from cache.
2026-03-17T14:16:28.133632Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 1 offset 0 partno 0 count 1 parts 0 suffix '63'
2026-03-17T14:16:28.133640Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.133646Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 1 count 1 size 134 from pos 0 cbcount 1
2026-03-17T14:16:28.133660Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.133675Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1026: Topic 'rt3.dc1--topic1' partition 1 user debug readTimeStamp done, result 1773756988132 queuesize 0 startOffset 0
2026-03-17T14:16:28.133689Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:884: session inited cookie: 3 partition: 2 MaxSeqNo: 0 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0
2026-03-17T14:16:28.133778Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:311: Caching head blob in L1. Partition 1 offset 1 count 2 size 288 actorID [17:7618228256901501957:2462]
2026-03-17T14:16:28.133793Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][1][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.133796Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:129: PQ Cache (L2). Adding blob. Tablet '72075186224037892' partition 1 offset 1 partno 0 count 2 parts 0 suffix '63' size 288
2026-03-17T14:16:28.133803Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][1][StateIdle] TPartition::HandleWriteResponse writeNewSize# 198 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.133807Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][1][StateIdle] TPartition::ReplyWrite. Partition: 1
2026-03-17T14:16:28.133811Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][1][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 1, SeqNo: 2, partNo: 0, Offset: 1 is stored on disk
2026-03-17T14:16:28.133813Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][1][StateIdle] TPartition::ReplyWrite. Partition: 1
2026-03-17T14:16:28.133815Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][1][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 1, SeqNo: 3, partNo: 0, Offset: 2 is stored on disk
2026-03-17T14:16:28.133825Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.133831Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.133832Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.133834Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.133836Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.133839Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][1][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.133846Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 3  requestId: <none> cookie: 2
2026-03-17T14:16:28.133853Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.134303Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 1 sessionId: f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0 grpc read done: success: 0 data: 
2026-03-17T14:16:28.134314Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:256: session v1 cookie: 1 sessionId: f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0 grpc read failed
2026-03-17T14:16:28.134320Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:232: session v1 cookie: 1 sessionId: f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0 grpc closed
2026-03-17T14:16:28.134323Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:304: session v1 cookie: 1 sessionId: f8c536e5-97ba97ea-fc91bf1f-34812e65|e1f0c628-c958e198-ffeb9bdd-f6ece7f_0 is DEAD
2026-03-17T14:16:28.134450Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=0) Received event: NActors::TEvents::TEvPoison
2026-03-17T14:16:28.134480Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 3 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 grpc read done: success: 1 data:  write_request[data omitted]
2026-03-17T14:16:28.134488Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 2 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 grpc read done: success: 0 data: 
2026-03-17T14:16:28.134492Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:256: session v1 cookie: 2 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 grpc read failed
2026-03-17T14:16:28.134499Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:232: session v1 cookie: 2 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 grpc closed
2026-03-17T14:16:28.134512Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:304: session v1 cookie: 2 sessionId: d007172b-e4e79599-c62f9cbc-9ffbe5b3|aa6ee7b5-efa2cb91-f17d99b5-8e4b1e69_0 is DEAD
2026-03-17T14:16:28.134516Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NKikimr::NPQ::TEvPartitionWriter::TEvWriteRequest
2026-03-17T14:16:28.134538Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2832: [PQ: 72075186224037892] server disconnected, pipe [17:7618228256901502147:2478] destroyed
2026-03-17T14:16:28.134552Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.134556Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.134567Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:140: [72075186224037892][Partition][0][StateIdle] TPartition::DropOwner.
2026-03-17T14:16:28.134579Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.134582Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.134583Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.134586Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.134588Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.134603Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 0  requestId: <none> cookie: 1
2026-03-17T14:16:28.134622Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.134645Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.134653Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.134667Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 2 SourceId: '' SeqNo: 1 partNo : 0 messageNo: 1 size 99 offset: -1
2026-03-17T14:16:28.134680Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:636: [72075186224037892][Partition][2][StateIdle] Received TPartition::TEvWrite
2026-03-17T14:16:28.134687Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.134696Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.134701Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.134706Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.134717Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.134732Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 part blob processing sourceId '' seqNo 1 partNo 0
2026-03-17T14:16:28.134746Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=1) Received event: NActors::TEvents::TEvPoison
2026-03-17T14:16:28.134765Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 part blob complete sourceId '' seqNo 1 partNo 0 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 166 count 1 nextOffset 1 batches 1
2026-03-17T14:16:28.134776Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.134778Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][2][StateIdle] Batch completed (1)
2026-03-17T14:16:28.134781Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.134819Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1711: [72075186224037892][Partition][2][StateIdle] Add new write blob: topic 'rt3.dc1--topic1' partition 2 compactOffset 0,1 HeadOffset 0 endOffset 0 curOffset 1 d0000000002_00000000000000000000_00000_0000000001_00000? size 154 WTime 1773756988134
2026-03-17T14:16:28.134848Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2832: [PQ: 72075186224037892] server disconnected, pipe [17:7618228256901502158:2480] destroyed
2026-03-17T14:16:28.134860Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.134869Z node 17 :PERSQUEUE DEBUG: read.h:313: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough blob. Partition 2 offset 0 partNo 0 count 1 size 154
2026-03-17T14:16:28.134886Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:140: [72075186224037892][Partition][1][StateIdle] TPartition::DropOwner.
2026-03-17T14:16:28.134896Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.134898Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.134901Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.134903Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.134905Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.134915Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 3 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 grpc read done: success: 1 data:  write_request[data omitted]
2026-03-17T14:16:28.134964Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NKikimr::NPQ::TEvPartitionWriter::TEvWriteRequest
2026-03-17T14:16:28.135001Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.135011Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.135024Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 2  requestId: <none> cookie: 2
2026-03-17T14:16:28.135048Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.135070Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.135077Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.135088Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 2 SourceId: '' SeqNo: 2 partNo : 0 messageNo: 3 size 99 offset: -1
2026-03-17T14:16:28.135095Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2077: [PQ: 72075186224037892] got client message topic: rt3.dc1--topic1 partition: 2 SourceId: '' SeqNo: 3 partNo : 0 messageNo: 3 size 99 offset: -1
2026-03-17T14:16:28.135106Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:636: [72075186224037892][Partition][2][StateIdle] Received TPartition::TEvWrite
2026-03-17T14:16:28.135113Z node 17 :PERSQUEUE DEBUG: partition.cpp:2334: [72075186224037892][Partition][2][StateIdle] Writing. Can't process user action and tx events
2026-03-17T14:16:28.135390Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:311: Caching head blob in L1. Partition 2 offset 0 count 1 size 154 actorID [17:7618228256901501957:2462]
2026-03-17T14:16:28.135411Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][2][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.135417Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:129: PQ Cache (L2). Adding blob. Tablet '72075186224037892' partition 2 offset 0 partno 0 count 1 parts 0 suffix '63' size 154
2026-03-17T14:16:28.135424Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][2][StateIdle] TPartition::HandleWriteResponse writeNewSize# 99 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.135428Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][2][StateIdle] TPartition::ReplyWrite. Partition: 2
2026-03-17T14:16:28.135433Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][2][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 2, SeqNo: 1, partNo: 0, Offset: 0 is stored on disk
2026-03-17T14:16:28.135451Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2026-03-17T14:16:28.135462Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:976: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user user send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 0
2026-03-17T14:16:28.135465Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user debug readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 2
2026-03-17T14:16:28.135468Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.135471Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.135476Z node 17 :PERSQUEUE DEBUG: partition.cpp:2452: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TMessage)
2026-03-17T14:16:28.135479Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 2, PendingWrites: 0
2026-03-17T14:16:28.135483Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.135492Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.135504Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 part blob processing sourceId '' seqNo 2 partNo 0
2026-03-17T14:16:28.135529Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 part blob complete sourceId '' seqNo 2 partNo 0 FormedBlobsCount 0 NewHead: Offset 1 PartNo 0 PackedSize 166 count 1 nextOffset 2 batches 1
2026-03-17T14:16:28.135540Z node 17 :PERSQUEUE DEBUG: partition.cpp:2516: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TMessage)
2026-03-17T14:16:28.135544Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1348: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 part blob processing sourceId '' seqNo 3 partNo 0
2026-03-17T14:16:28.135549Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1452: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 part blob complete sourceId '' seqNo 3 partNo 0 FormedBlobsCount 0 NewHead: Offset 1 PartNo 0 PackedSize 300 count 2 nextOffset 3 batches 1
2026-03-17T14:16:28.135553Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 2
2026-03-17T14:16:28.135555Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][2][StateIdle] Batch completed (2)
2026-03-17T14:16:28.135558Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.135581Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:1711: [72075186224037892][Partition][2][StateIdle] Add new write blob: topic 'rt3.dc1--topic1' partition 2 compactOffset 1,2 HeadOffset 1 endOffset 1 curOffset 3 d0000000002_00000000000000000001_00000_0000000002_00000? size 288 WTime 1773756988135
2026-03-17T14:16:28.135599Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][2][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.135606Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 1  requestId: <none> cookie: 1
2026-03-17T14:16:28.135623Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.135633Z node 17 :PERSQUEUE DEBUG: read.h:313: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough blob. Partition 2 offset 1 partNo 0 count 2 size 288
2026-03-17T14:16:28.135634Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.135662Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][2][StateIdle] read cookie 3 Topic 'rt3.dc1--topic1' partition 2 user user offset 0 partno 0 count 1 size 1024000 endOffset 1 max time lag 0ms effective offset 0
2026-03-17T14:16:28.135681Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][2][StateIdle] read cookie 3 added 1 blobs, size 154 count 1 last offset 0, current partition end offset: 1
2026-03-17T14:16:28.135689Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][2][StateIdle] Reading cookie 3. Send blob request.
2026-03-17T14:16:28.135701Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 2 offset 0 partno 0 count 1 parts_count 0 source 1 size 154 accessed 0 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.135718Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 3. All 1 blobs are from cache.
2026-03-17T14:16:28.135727Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 2 offset 0 partno 0 count 1 parts 0 suffix '63'
2026-03-17T14:16:28.135794Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.135806Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 1 count 1 size 134 from pos 0 cbcount 1
2026-03-17T14:16:28.135818Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1026: Topic 'rt3.dc1--topic1' partition 2 user user readTimeStamp done, result 1773756988134 queuesize 1 startOffset 0
2026-03-17T14:16:28.135822Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:934: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user debug readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 2
2026-03-17T14:16:28.135826Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:976: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user debug send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 2
2026-03-17T14:16:28.135853Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][2][StateIdle] read cookie 4 Topic 'rt3.dc1--topic1' partition 2 user debug offset 0 partno 0 count 1 size 1024000 endOffset 1 max time lag 0ms effective offset 0
2026-03-17T14:16:28.135864Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][2][StateIdle] read cookie 4 added 1 blobs, size 154 count 1 last offset 0, current partition end offset: 1
2026-03-17T14:16:28.135865Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][2][StateIdle] Reading cookie 4. Send blob request.
2026-03-17T14:16:28.135871Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 2 offset 0 partno 0 count 1 parts_count 0 source 1 size 154 accessed 1 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.135879Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 4. All 1 blobs are from cache.
2026-03-17T14:16:28.135884Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 2 offset 0 partno 0 count 1 parts 0 suffix '63'
2026-03-17T14:16:28.135885Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.135891Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 1 count 1 size 134 from pos 0 cbcount 1
2026-03-17T14:16:28.135899Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1026: Topic 'rt3.dc1--topic1' partition 2 user debug readTimeStamp done, result 1773756988134 queuesize 0 startOffset 0
2026-03-17T14:16:28.136210Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:311: Caching head blob in L1. Partition 2 offset 1 count 2 size 288 actorID [17:7618228256901501957:2462]
2026-03-17T14:16:28.136231Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][2][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.136242Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:129: PQ Cache (L2). Adding blob. Tablet '72075186224037892' partition 2 offset 1 partno 0 count 2 parts 0 suffix '63' size 288
2026-03-17T14:16:28.136244Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][2][StateIdle] TPartition::HandleWriteResponse writeNewSize# 198 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.136249Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][2][StateIdle] TPartition::ReplyWrite. Partition: 2
2026-03-17T14:16:28.136254Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][2][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 2, SeqNo: 2, partNo: 0, Offset: 1 is stored on disk
2026-03-17T14:16:28.136257Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:60: [72075186224037892][Partition][2][StateIdle] TPartition::ReplyWrite. Partition: 2
2026-03-17T14:16:28.136261Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:365: [72075186224037892][Partition][2][StateIdle] Answering for message sourceid: '', Topic: 'rt3.dc1--topic1', Partition: 2, SeqNo: 3, partNo: 0, Offset: 2 is stored on disk
2026-03-17T14:16:28.136276Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.136285Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.136289Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.136291Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.136293Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.136298Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][2][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.136307Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 3  requestId: <none> cookie: 2
2026-03-17T14:16:28.136327Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NKikimr::TEvPersQueue::TEvResponse
2026-03-17T14:16:28.202964Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.202985Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.202987Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.202992Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.202996Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.203962Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.203976Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.203980Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.203982Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.203985Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.204452Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.204466Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.204469Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.204476Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.204478Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
Start reads
2026-03-17T14:16:28.234658Z node 17 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 3 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 grpc read done: success: 0 data: 
2026-03-17T14:16:28.234682Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:256: session v1 cookie: 3 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 grpc read failed
2026-03-17T14:16:28.234703Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:232: session v1 cookie: 3 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 grpc closed
2026-03-17T14:16:28.234712Z node 17 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:304: session v1 cookie: 3 sessionId: 7f73289e-b235a64e-e3c1c5c8-259157e7|94296678-e4fff4ad-889e6943-d166ef3a_0 is DEAD
2026-03-17T14:16:28.234881Z node 17 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037892 (partition=2) Received event: NActors::TEvents::TEvPoison
2026-03-17T14:16:28.234955Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2832: [PQ: 72075186224037892] server disconnected, pipe [17:7618228256901502171:2482] destroyed
2026-03-17T14:16:28.234970Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:140: [72075186224037892][Partition][2][StateIdle] TPartition::DropOwner.
2026-03-17T14:16:28.234980Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.234984Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.234987Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.234991Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.234993Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.235509Z node 17 :PQ_READ_PROXY DEBUG: grpc_pq_read.h:111: new grpc connection
2026-03-17T14:16:28.235523Z node 17 :PQ_READ_PROXY DEBUG: grpc_pq_read.h:133: new session created cookie 1
2026-03-17T14:16:28.235741Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { path: "rt3.dc1--topic1" } consumer: "debug" } }
2026-03-17T14:16:28.235805Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:944: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 read init: from# ipv6:[::1]:36988, request# { init_request { topics_read_settings { path: "rt3.dc1--topic1" } consumer: "debug" } }
2026-03-17T14:16:28.235934Z node 17 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:41: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 auth for : debug
2026-03-17T14:16:28.236195Z node 17 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:142: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Handle describe topics response
2026-03-17T14:16:28.236274Z node 17 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:68: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 auth is DEAD
2026-03-17T14:16:28.236276Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:1061: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 auth ok: topics# 1, initDone# 0
2026-03-17T14:16:28.236530Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:1232: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 register session: topic# rt3.dc1--topic1
2026-03-17T14:16:28.236802Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1669: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502188:2484] connected; active server actors: 1
2026-03-17T14:16:28.236893Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { read_request { bytes_size: 52428800 } }
2026-03-17T14:16:28.236924Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1857: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got read request: guid# aacbb8e2-bcfea02b-5c70007f-962dfcd1
2026-03-17T14:16:28.236924Z node 18 :PERSQUEUE_READ_BALANCER NOTICE: read_balancer__balancing.cpp:1720: [72075186224037893][rt3.dc1--topic1] consumer "debug" register session for pipe [17:7618228256901502188:2484] session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.236941Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:639: [72075186224037893][rt3.dc1--topic1] consumer debug register readable partition 0
2026-03-17T14:16:28.236954Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:669: [72075186224037893][rt3.dc1--topic1] consumer debug family created family=1 (Status=Free, Partitions=[0])
2026-03-17T14:16:28.236956Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:639: [72075186224037893][rt3.dc1--topic1] consumer debug register readable partition 1
2026-03-17T14:16:28.236960Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:669: [72075186224037893][rt3.dc1--topic1] consumer debug family created family=2 (Status=Free, Partitions=[1])
2026-03-17T14:16:28.236962Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:639: [72075186224037893][rt3.dc1--topic1] consumer debug register readable partition 2
2026-03-17T14:16:28.236966Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:669: [72075186224037893][rt3.dc1--topic1] consumer debug family created family=3 (Status=Free, Partitions=[2])
2026-03-17T14:16:28.236972Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:871: [72075186224037893][rt3.dc1--topic1] consumer debug register reading session ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=0)
2026-03-17T14:16:28.236975Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1187: [72075186224037893][rt3.dc1--topic1] consumer debug rebalancing was scheduled
2026-03-17T14:16:28.236985Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1259: [72075186224037893][rt3.dc1--topic1] consumer debug balancing. Sessions=1, Families=3, UnreadableFamilies=3 [3 (2), 2 (1), 1 (0), ], RequireBalancing=0 []
2026-03-17T14:16:28.236994Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1306: [72075186224037893][rt3.dc1--topic1] consumer debug balancing family=3 (Status=Free, Partitions=[2]) for ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=0)
2026-03-17T14:16:28.237007Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:549: [72075186224037893][rt3.dc1--topic1] consumer debug family 3 status Active partitions [2] session "shared/debug_17_1_10175277978384791095_v1" sender [17:7618228256901502185:2484] lock partition 2 for ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=1) generation 1 step 1
2026-03-17T14:16:28.237022Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1306: [72075186224037893][rt3.dc1--topic1] consumer debug balancing family=2 (Status=Free, Partitions=[1]) for ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=1)
2026-03-17T14:16:28.237027Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:549: [72075186224037893][rt3.dc1--topic1] consumer debug family 2 status Active partitions [1] session "shared/debug_17_1_10175277978384791095_v1" sender [17:7618228256901502185:2484] lock partition 1 for ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=2) generation 1 step 2
2026-03-17T14:16:28.237035Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1306: [72075186224037893][rt3.dc1--topic1] consumer debug balancing family=1 (Status=Free, Partitions=[0]) for ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=2)
2026-03-17T14:16:28.237042Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:549: [72075186224037893][rt3.dc1--topic1] consumer debug family 1 status Active partitions [0] session "shared/debug_17_1_10175277978384791095_v1" sender [17:7618228256901502185:2484] lock partition 0 for ReadingSession "shared/debug_17_1_10175277978384791095_v1" (Sender=[17:7618228256901502185:2484], Pipe=[17:7618228256901502188:2484], Partitions=[], ActiveFamilyCount=3) generation 1 step 3
2026-03-17T14:16:28.237053Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1326: [72075186224037893][rt3.dc1--topic1] consumer debug start rebalancing. familyCount=3, sessionCount=1, desiredFamilyCount=3, allowPlusOne=0
2026-03-17T14:16:28.237058Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1404: [72075186224037893][rt3.dc1--topic1] consumer debug balancing duration: 0.000070s
2026-03-17T14:16:28.237366Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:1354: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 from= ipv6:[::1]:36988 user=- topic=Topic rt3.dc1--topic1 in dc dc1 in database: Root assign: record# { Partition: 2 TabletId: 72075186224037892 Topic: "rt3.dc1--topic1" Generation: 1 Step: 1 Session: "shared/debug_17_1_10175277978384791095_v1" ClientId: "debug" PipeClient { RawX1: 7618228256901502188 RawX2: 4503672641817012 } Path: "/Root/PQ/rt3.dc1--topic1" }
2026-03-17T14:16:28.237417Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1204: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 INITING TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1)
2026-03-17T14:16:28.237419Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:1354: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 from= ipv6:[::1]:36988 user=- topic=Topic rt3.dc1--topic1 in dc dc1 in database: Root assign: record# { Partition: 1 TabletId: 72075186224037892 Topic: "rt3.dc1--topic1" Generation: 1 Step: 2 Session: "shared/debug_17_1_10175277978384791095_v1" ClientId: "debug" PipeClient { RawX1: 7618228256901502188 RawX2: 4503672641817012 } Path: "/Root/PQ/rt3.dc1--topic1" }
2026-03-17T14:16:28.237445Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1204: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 INITING TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2)
2026-03-17T14:16:28.237462Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:1354: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 from= ipv6:[::1]:36988 user=- topic=Topic rt3.dc1--topic1 in dc dc1 in database: Root assign: record# { Partition: 0 TabletId: 72075186224037892 Topic: "rt3.dc1--topic1" Generation: 1 Step: 3 Session: "shared/debug_17_1_10175277978384791095_v1" ClientId: "debug" PipeClient { RawX1: 7618228256901502188 RawX2: 4503672641817012 } Path: "/Root/PQ/rt3.dc1--topic1" }
2026-03-17T14:16:28.237479Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1022: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [17:7618228256901502191:2487]
2026-03-17T14:16:28.237484Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1022: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [17:7618228256901502192:2488]
2026-03-17T14:16:28.237487Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901502191:2487], now have 1 active actors on pipe
2026-03-17T14:16:28.237488Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1204: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 INITING TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3)
2026-03-17T14:16:28.237493Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901502192:2488], now have 1 active actors on pipe
2026-03-17T14:16:28.237500Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.237507Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.237512Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1022: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [17:7618228256901502196:2489]
2026-03-17T14:16:28.237520Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:1764: [PQ: 72075186224037892] Created session shared/debug_17_1_10175277978384791095_v1 on pipe: [17:7618228256901502191:2487]
2026-03-17T14:16:28.237533Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:283: Direct read cache: registered server session: shared/debug_17_1_10175277978384791095_v1:1 with generation 1
2026-03-17T14:16:28.237535Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.237538Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.237542Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:1764: [PQ: 72075186224037892] Created session shared/debug_17_1_10175277978384791095_v1 on pipe: [17:7618228256901502192:2488]
2026-03-17T14:16:28.237546Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:283: Direct read cache: registered server session: shared/debug_17_1_10175277978384791095_v1:2 with generation 1
2026-03-17T14:16:28.237548Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2807: [PQ: 72075186224037892] server connected, pipe [17:7618228256901502196:2489], now have 1 active actors on pipe
2026-03-17T14:16:28.237551Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.237556Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 0
2026-03-17T14:16:28.237560Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:1764: [PQ: 72075186224037892] Created session shared/debug_17_1_10175277978384791095_v1 on pipe: [17:7618228256901502196:2489]
2026-03-17T14:16:28.237565Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:283: Direct read cache: registered server session: shared/debug_17_1_10175277978384791095_v1:3 with generation 1
2026-03-17T14:16:28.237577Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.237583Z node 17 :PERSQUEUE DEBUG: partition.cpp:2438: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxEvent(TEvPQ::TEvSetClientInfo)
2026-03-17T14:16:28.237599Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.237601Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.237605Z node 17 :PERSQUEUE DEBUG: partition.cpp:2502: [72075186224037892][Partition][2][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TEvPQ::TEvSetClientInfo)
2026-03-17T14:16:28.237624Z node 17 :PERSQUEUE DEBUG: partition.cpp:3940: [72075186224037892][Partition][2][StateIdle] Topic 'rt3.dc1--topic1' partition 2 user debug session is set to 0 (startOffset 0) session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.237633Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.237636Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][2][StateIdle] Batch completed (1)
2026-03-17T14:16:28.237640Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.237680Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.237690Z node 17 :PERSQUEUE DEBUG: partition.cpp:2438: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxEvent(TEvPQ::TEvSetClientInfo)
2026-03-17T14:16:28.237694Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.237696Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.237699Z node 17 :PERSQUEUE DEBUG: partition.cpp:2502: [72075186224037892][Partition][1][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TEvPQ::TEvSetClientInfo)
2026-03-17T14:16:28.237707Z node 17 :PERSQUEUE DEBUG: partition.cpp:3940: [72075186224037892][Partition][1][StateIdle] Topic 'rt3.dc1--topic1' partition 1 user debug session is set to 0 (startOffset 0) session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.237710Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.237712Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][1][StateIdle] Batch completed (1)
2026-03-17T14:16:28.237716Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.237735Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.237737Z node 17 :PERSQUEUE DEBUG: partition.cpp:2438: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxEvent(TEvPQ::TEvSetClientInfo)
2026-03-17T14:16:28.237742Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 1, PendingWrites: 0
2026-03-17T14:16:28.237744Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.237747Z node 17 :PERSQUEUE DEBUG: partition.cpp:2502: [72075186224037892][Partition][0][StateIdle] TPartition::ProcessUserActionAndTxPendingCommit(TEvPQ::TEvSetClientInfo)
2026-03-17T14:16:28.237757Z node 17 :PERSQUEUE DEBUG: partition.cpp:3940: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc1--topic1' partition 0 user debug session is set to 0 (startOffset 0) session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.237759Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 1
2026-03-17T14:16:28.237762Z node 17 :PERSQUEUE DEBUG: partition.cpp:2371: [72075186224037892][Partition][0][StateIdle] Batch completed (1)
2026-03-17T14:16:28.237765Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.237783Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.237799Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.237810Z node 17 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2026-03-17T14:16:28.238753Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][2][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.238807Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][2][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.238823Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.238826Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.238829Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.238834Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.238836Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.238843Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][2][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.238892Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 0  requestId: <none> cookie: 2
2026-03-17T14:16:28.238925Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][1][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.238946Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][1][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.238956Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.238959Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.238962Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.238965Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.238966Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.238969Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][1][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.238974Z node 17 :PERSQUEUE DEBUG: partition.cpp:2182: [72075186224037892][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2026-03-17T14:16:28.238991Z node 17 :PERSQUEUE DEBUG: partition_write.cpp:572: [72075186224037892][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2026-03-17T14:16:28.239000Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.239002Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.239003Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.239006Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.239009Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.239012Z node 17 :PERSQUEUE DEBUG: partition_compaction.cpp:193: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2026-03-17T14:16:28.239017Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 0  requestId: <none> cookie: 2
2026-03-17T14:16:28.239021Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:903: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 3 WriteTimestampMS: 1773756988134 CreateTimestampMS: 1773756988133 SizeLag: 442 WriteTimestampEstimateMS: 1773756988234 ClientHasAnyCommits: false } Cookie: 2 }
2026-03-17T14:16:28.239024Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 2
2026-03-17T14:16:28.239039Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:631: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 INIT DONE TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) EndOffset 3 readOffset 0 committedOffset 0
2026-03-17T14:16:28.239063Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:903: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 3 WriteTimestampMS: 1773756988132 CreateTimestampMS: 1773756988131 SizeLag: 442 WriteTimestampEstimateMS: 1773756988202 ClientHasAnyCommits: false } Cookie: 2 }
2026-03-17T14:16:28.239068Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:903: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 3 WriteTimestampMS: 1773756988130 CreateTimestampMS: 1773756988129 SizeLag: 409 WriteTimestampEstimateMS: 1773756988204 ClientHasAnyCommits: false } Cookie: 2 }
2026-03-17T14:16:28.239071Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:631: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 INIT DONE TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) EndOffset 3 readOffset 0 committedOffset 0
2026-03-17T14:16:28.239078Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:631: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 INIT DONE TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) EndOffset 3 readOffset 0 committedOffset 0
2026-03-17T14:16:28.239093Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1453: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 sending to client partition status
2026-03-17T14:16:28.239229Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1453: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 sending to client partition status
2026-03-17T14:16:28.239243Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1453: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 sending to client partition status
Got start stream event
Got start stream event
2026-03-17T14:16:28.239657Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 1 } }
Got start stream event
2026-03-17T14:16:28.239705Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:551: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got StartRead from client: partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1), readOffset# 0, commitOffset# (empty maybe)
2026-03-17T14:16:28.239722Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 3 } }
2026-03-17T14:16:28.239730Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1084: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Start reading TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) EndOffset 3 readOffset 0 committedOffset 0 clientCommitOffset (empty maybe) clientReadOffset 0
2026-03-17T14:16:28.239737Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1008: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) ready for read with readOffset 0 endOffset 3
2026-03-17T14:16:28.239748Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:551: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got StartRead from client: partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3), readOffset# 0, commitOffset# (empty maybe)
2026-03-17T14:16:28.239759Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1084: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Start reading TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) EndOffset 3 readOffset 0 committedOffset 0 clientCommitOffset (empty maybe) clientReadOffset 0
2026-03-17T14:16:28.239762Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1008: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) ready for read with readOffset 0 endOffset 3
2026-03-17T14:16:28.239768Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2350: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 partition ready for read: partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1), readOffset# 0, endOffset# 3, WTime# 1773756988134, sizeLag# 442
2026-03-17T14:16:28.239771Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2361: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TEvPartitionReady. Aval parts: 1
2026-03-17T14:16:28.239781Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2284: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 performing read request: guid# 2e905440-bd968aef-4e0f66af-ce2321c, from# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1), count# 3, size# 530, partitionsAsked# 1, maxTimeLag# 0ms
2026-03-17T14:16:28.239804Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 2 } }
2026-03-17T14:16:28.239805Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1458: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 READ FROM TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) maxCount 3 maxSize 530 maxTimeLagMs 0 readTimestampMs 0 readOffset 0 EndOffset 3 ClientCommitOffset 0 committedOffset 0 Guid 2e905440-bd968aef-4e0f66af-ce2321c
2026-03-17T14:16:28.239860Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2350: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 partition ready for read: partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3), readOffset# 0, endOffset# 3, WTime# 1773756988130, sizeLag# 409
2026-03-17T14:16:28.239867Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2361: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TEvPartitionReady. Aval parts: 1
2026-03-17T14:16:28.239871Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2284: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 performing read request: guid# 5fdcaa2e-bd163144-63e03f24-65de710d, from# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3), count# 3, size# 490, partitionsAsked# 1, maxTimeLag# 0ms
2026-03-17T14:16:28.239880Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:551: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got StartRead from client: partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2), readOffset# 0, commitOffset# (empty maybe)
2026-03-17T14:16:28.239892Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.239901Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 2
2026-03-17T14:16:28.239902Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1458: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 READ FROM TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) maxCount 3 maxSize 490 maxTimeLagMs 0 readTimestampMs 0 readOffset 0 EndOffset 3 ClientCommitOffset 0 committedOffset 0 Guid 5fdcaa2e-bd163144-63e03f24-65de710d
2026-03-17T14:16:28.239920Z node 17 :PQ_READ_PROXY INFO: partition_actor.cpp:1084: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Start reading TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) EndOffset 3 readOffset 0 committedOffset 0 clientCommitOffset (empty maybe) clientReadOffset 0
2026-03-17T14:16:28.239927Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1008: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) ready for read with readOffset 0 endOffset 3
2026-03-17T14:16:28.239930Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.239933Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 0
2026-03-17T14:16:28.239934Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2350: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 partition ready for read: partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2), readOffset# 0, endOffset# 3, WTime# 1773756988132, sizeLag# 442
2026-03-17T14:16:28.239936Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2361: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TEvPartitionReady. Aval parts: 1
2026-03-17T14:16:28.239941Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2284: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 performing read request: guid# b84afdc4-be985956-c1ac786f-10d6aa3c, from# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2), count# 3, size# 530, partitionsAsked# 1, maxTimeLag# 0ms
2026-03-17T14:16:28.239963Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1458: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 READ FROM TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) maxCount 3 maxSize 530 maxTimeLagMs 0 readTimestampMs 0 readOffset 0 EndOffset 3 ClientCommitOffset 0 committedOffset 0 Guid b84afdc4-be985956-c1ac786f-10d6aa3c
2026-03-17T14:16:28.239977Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][2][StateIdle] read cookie 5 Topic 'rt3.dc1--topic1' partition 2 user debug offset 0 partno 0 count 3 size 530 endOffset 3 max time lag 0ms effective offset 0
2026-03-17T14:16:28.240025Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][2][StateIdle] read cookie 5 added 2 blobs, size 442 count 3 last offset 1, current partition end offset: 3
2026-03-17T14:16:28.240036Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][2][StateIdle] Reading cookie 5. Send blob request.
2026-03-17T14:16:28.240045Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][0][StateIdle] read cookie 5 Topic 'rt3.dc1--topic1' partition 0 user debug offset 0 partno 0 count 3 size 490 endOffset 3 max time lag 0ms effective offset 0
2026-03-17T14:16:28.240064Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][0][StateIdle] read cookie 5 added 1 blobs, size 409 count 3 last offset 0, current partition end offset: 3
2026-03-17T14:16:28.240066Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][0][StateIdle] Reading cookie 5. Send blob request.
2026-03-17T14:16:28.240076Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:148: Handle TEvRequest topic: 'rt3.dc1--topic1' requestId: <none>
2026-03-17T14:16:28.240084Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2718: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--topic1' partition 1
2026-03-17T14:16:28.240099Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 2 offset 0 partno 0 count 1 parts_count 0 source 1 size 154 accessed 2 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.240108Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 2 offset 1 partno 0 count 2 parts_count 0 source 1 size 288 accessed 0 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.240138Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 5. All 2 blobs are from cache.
2026-03-17T14:16:28.240147Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 0 offset 0 partno 0 count 3 parts_count 0 source 1 size 409 accessed 2 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.240150Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 5. All 1 blobs are from cache.
2026-03-17T14:16:28.240160Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 2 blobs
2026-03-17T14:16:28.240165Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 2 offset 0 partno 0 count 1 parts 0 suffix '63'
2026-03-17T14:16:28.240170Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 2 offset 1 partno 0 count 2 parts 0 suffix '63'
2026-03-17T14:16:28.240172Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 1 count 1 size 134 from pos 0 cbcount 1
2026-03-17T14:16:28.240179Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 0 offset 0 partno 0 count 3 parts 0 suffix '63'
2026-03-17T14:16:28.240182Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 1 totakecount 2 count 2 size 268 from pos 0 cbcount 2
2026-03-17T14:16:28.240199Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 1 blobs
2026-03-17T14:16:28.240206Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 3 count 3 size 389 from pos 0 cbcount 3
2026-03-17T14:16:28.240227Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 2 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.240240Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.240249Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:891: [72075186224037892][Partition][1][StateIdle] read cookie 5 Topic 'rt3.dc1--topic1' partition 1 user debug offset 0 partno 0 count 3 size 530 endOffset 3 max time lag 0ms effective offset 0
2026-03-17T14:16:28.240262Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1116: [72075186224037892][Partition][1][StateIdle] read cookie 5 added 2 blobs, size 442 count 3 last offset 1, current partition end offset: 3
2026-03-17T14:16:28.240268Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:1132: [72075186224037892][Partition][1][StateIdle] Reading cookie 5. Send blob request.
2026-03-17T14:16:28.240296Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 1 offset 0 partno 0 count 1 parts_count 0 source 1 size 154 accessed 2 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.240304Z node 17 :PERSQUEUE DEBUG: cache_eviction.h:487: Got data from cache. Partition 1 offset 1 partno 0 count 2 parts_count 0 source 1 size 288 accessed 0 times before, last time 2026-03-17T14:16:28.000000Z
2026-03-17T14:16:28.240321Z node 17 :PERSQUEUE DEBUG: read.h:126: [72075186224037892][PQCacheProxy]Reading cookie 5. All 2 blobs are from cache.
2026-03-17T14:16:28.240330Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:580: FormAnswer for 2 blobs
2026-03-17T14:16:28.240339Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 0 totakecount 1 count 1 size 134 from pos 0 cbcount 1
2026-03-17T14:16:28.240349Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 1 offset 0 partno 0 count 1 parts 0 suffix '63'
2026-03-17T14:16:28.240350Z node 17 :PERSQUEUE DEBUG: partition_read.cpp:500: FormAnswer processing batch offset 1 totakecount 2 count 2 size 268 from pos 0 cbcount 2
2026-03-17T14:16:28.240357Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:903: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) initDone 1 event { CmdReadResult { MaxOffset: 3 Result { Offset: 0 Data: "... 99 bytes ..." SourceId: "" SeqNo: 1 WriteTimestampMS: 1773756988134 CreateTimestampMS: 1773756988133 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } Result { Offset: 1 Data: "... 99 bytes ..." SourceId: "" SeqNo: 2 WriteTimestampMS: 1773756988135 CreateTimestampMS: 1773756988133 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } Result { Offset: 2 Data: "... 99 bytes ..." SourceId: "" SeqNo: 3 WriteTimestampMS: 1773756988135 CreateTimestampMS: 1773756988133 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } BlobsFromDisk: 0 BlobsFromCache: 2 SizeLag: 40 RealReadOffset: 2 WaitQuotaTimeMs: 0 EndOffset: 3 StartOffset: 0 } Cookie: 0 }
2026-03-17T14:16:28.240359Z node 17 :PERSQUEUE DEBUG: pq_l2_cache.cpp:201: PQ Cache (L2). Touched. Tablet '72075186224037892' partition 1 offset 1 partno 0 count 2 parts 0 suffix '63'
2026-03-17T14:16:28.240363Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:183: Answer ok topic: 'rt3.dc1--topic1' partition: 1 messageNo: 0  requestId: <none> cookie: 0
2026-03-17T14:16:28.240400Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:814: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) isMemoryLimitReached 0 EndOffset 3 ReadOffset 3 read result size 3
2026-03-17T14:16:28.240406Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:903: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) initDone 1 event { CmdReadResult { MaxOffset: 3 Result { Offset: 0 Data: "... 99 bytes ..." SourceId: "" SeqNo: 1 WriteTimestampMS: 1773756988130 CreateTimestampMS: 1773756988129 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } Result { Offset: 1 Data: "... 99 bytes ..." SourceId: "" SeqNo: 2 WriteTimestampMS: 1773756988130 CreateTimestampMS: 1773756988129 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } Result { Offset: 2 Data: "... 99 bytes ..." SourceId: "" SeqNo: 3 WriteTimestampMS: 1773756988130 CreateTimestampMS: 1773756988129 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } BlobsFromDisk: 0 BlobsFromCache: 1 SizeLag: 7 RealReadOffset: 2 WaitQuotaTimeMs: 0 EndOffset: 3 StartOffset: 0 } Cookie: 0 }
2026-03-17T14:16:28.240412Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1338: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) wait data in partition inited, cookie 1 from offset 3
2026-03-17T14:16:28.240419Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:828: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 after read state TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1) EndOffset 3 ReadOffset 3 ReadGuid 2e905440-bd968aef-4e0f66af-ce2321c has messages 1
2026-03-17T14:16:28.240422Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:814: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) isMemoryLimitReached 0 EndOffset 3 ReadOffset 3 read result size 3
2026-03-17T14:16:28.240424Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1338: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) wait data in partition inited, cookie 1 from offset 3
2026-03-17T14:16:28.240428Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:828: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 after read state TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3) EndOffset 3 ReadOffset 3 ReadGuid 5fdcaa2e-bd163144-63e03f24-65de710d has messages 1
2026-03-17T14:16:28.240453Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1958: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 read done: guid# 2e905440-bd968aef-4e0f66af-ce2321c, partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 2(assignId:1), size# 381
2026-03-17T14:16:28.240464Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:903: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) initDone 1 event { CmdReadResult { MaxOffset: 3 Result { Offset: 0 Data: "... 99 bytes ..." SourceId: "" SeqNo: 1 WriteTimestampMS: 1773756988132 CreateTimestampMS: 1773756988131 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } Result { Offset: 1 Data: "... 99 bytes ..." SourceId: "" SeqNo: 2 WriteTimestampMS: 1773756988132 CreateTimestampMS: 1773756988131 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } Result { Offset: 2 Data: "... 99 bytes ..." SourceId: "" SeqNo: 3 WriteTimestampMS: 1773756988132 CreateTimestampMS: 1773756988131 UncompressedSize: 8 PartitionKey: "" ExplicitHash: "" } BlobsFromDisk: 0 BlobsFromCache: 2 SizeLag: 40 RealReadOffset: 2 WaitQuotaTimeMs: 0 EndOffset: 3 StartOffset: 0 } Cookie: 0 }
2026-03-17T14:16:28.240467Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2120: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 response to read: guid# 2e905440-bd968aef-4e0f66af-ce2321c
2026-03-17T14:16:28.240476Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:814: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) isMemoryLimitReached 0 EndOffset 3 ReadOffset 3 read result size 3
2026-03-17T14:16:28.240478Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:1338: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) wait data in partition inited, cookie 1 from offset 3
2026-03-17T14:16:28.240481Z node 17 :PQ_READ_PROXY DEBUG: partition_actor.cpp:828: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 after read state TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2) EndOffset 3 ReadOffset 3 ReadGuid b84afdc4-be985956-c1ac786f-10d6aa3c has messages 1
2026-03-17T14:16:28.240560Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2163: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Process answer. Aval parts: 0
2026-03-17T14:16:28.240589Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1958: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 read done: guid# 5fdcaa2e-bd163144-63e03f24-65de710d, partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 0(assignId:3), size# 272
2026-03-17T14:16:28.240593Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2120: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 response to read: guid# 5fdcaa2e-bd163144-63e03f24-65de710d
2026-03-17T14:16:28.240632Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2163: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Process answer. Aval parts: 0
2026-03-17T14:16:28.240644Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1958: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 read done: guid# b84afdc4-be985956-c1ac786f-10d6aa3c, partition# TopicId: Topic rt3.dc1--topic1 in dc dc1 in database: Root, partition 1(assignId:2), size# 272
2026-03-17T14:16:28.240646Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2120: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 response to read: guid# b84afdc4-be985956-c1ac786f-10d6aa3c
2026-03-17T14:16:28.240671Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:2163: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 Process answer. Aval parts: 0
Got data event with total 3 messages, current total messages: 3
2026-03-17T14:16:28.240893Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { read_request { bytes_size: 381 } }
2026-03-17T14:16:28.240931Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1857: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got read request: guid# 94405423-eba453a8-6fd38520-b5e8ed3b
2026-03-17T14:16:28.240958Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { read_request { bytes_size: 272 } }
2026-03-17T14:16:28.240966Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1857: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got read request: guid# 23143df0-eab54350-6047853-801584bd
Got data event with total 3 messages, current total messages: 6
Got data event with total 3 messages, current total messages: 9
2026-03-17T14:16:28.241071Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 1, data# { read_request { bytes_size: 272 } }
2026-03-17T14:16:28.241081Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:1857: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 got read request: guid# a63d6ef5-56084eae-c679f0a1-46a53d48
2026-03-17T14:16:28.241339Z node 17 :PQ_READ_PROXY DEBUG: read_session_actor.cpp:122: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read done: success# 0, data# {  }
2026-03-17T14:16:28.241348Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:125: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc read failed
2026-03-17T14:16:28.241353Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:92: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 grpc closed
2026-03-17T14:16:28.241369Z node 17 :PQ_READ_PROXY INFO: read_session_actor.cpp:383: session cookie 1 consumer shared/debug session shared/debug_17_1_10175277978384791095_v1 is DEAD
2026-03-17T14:16:28.241479Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2324: [PQ: 72075186224037892] Destroy direct read session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.241492Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2832: [PQ: 72075186224037892] server disconnected, pipe [17:7618228256901502196:2489] destroyed
2026-03-17T14:16:28.241497Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2324: [PQ: 72075186224037892] Destroy direct read session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.241504Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2832: [PQ: 72075186224037892] server disconnected, pipe [17:7618228256901502192:2488] destroyed
2026-03-17T14:16:28.241507Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2324: [PQ: 72075186224037892] Destroy direct read session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.241510Z node 17 :PERSQUEUE DEBUG: pq_impl.cpp:2832: [PQ: 72075186224037892] server disconnected, pipe [17:7618228256901502191:2487] destroyed
2026-03-17T14:16:28.241524Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:139: Direct read cache: server session deregistered: shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.241531Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:139: Direct read cache: server session deregistered: shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.241533Z node 17 :PQ_READ_PROXY DEBUG: caching_service.cpp:139: Direct read cache: server session deregistered: shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.241687Z node 18 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1673: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502188:2484] disconnected.
2026-03-17T14:16:28.241706Z node 18 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1684: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502188:2484] disconnected; active server actors: 1
2026-03-17T14:16:28.241711Z node 18 :PERSQUEUE_READ_BALANCER NOTICE: read_balancer__balancing.cpp:1693: [72075186224037893][rt3.dc1--topic1] pipe [17:7618228256901502188:2484] client debug disconnected session shared/debug_17_1_10175277978384791095_v1
2026-03-17T14:16:28.303262Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.303283Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.303286Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.303291Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.303294Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.304299Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.304315Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.304317Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.304319Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.304322Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.304795Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.304804Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.304806Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.304808Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.304810Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.403652Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.403673Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.403676Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.403680Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.403683Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.404674Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.404714Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.404717Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.404720Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.404723Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.405135Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.405150Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.405152Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.405155Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.405158Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.504045Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.504069Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.504072Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.504077Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.504081Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.505021Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.505028Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.505033Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.505038Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.505040Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.505620Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.505629Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.505631Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.505633Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.505635Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
2026-03-17T14:16:28.604367Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][1][StateIdle] Process user action and tx events
2026-03-17T14:16:28.604388Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.604391Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][1][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.604395Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][1][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.604399Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][1][StateIdle] Try persist
2026-03-17T14:16:28.605516Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][2][StateIdle] Process user action and tx events
2026-03-17T14:16:28.605531Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.605534Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][2][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.605542Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][2][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.605544Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][2][StateIdle] Try persist
2026-03-17T14:16:28.605856Z node 17 :PERSQUEUE DEBUG: partition.cpp:2358: [72075186224037892][Partition][0][StateIdle] Process user action and tx events
2026-03-17T14:16:28.605859Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.605860Z node 17 :PERSQUEUE DEBUG: partition.cpp:2366: [72075186224037892][Partition][0][StateIdle] Process user action and tx pending commits
2026-03-17T14:16:28.605863Z node 17 :PERSQUEUE DEBUG: partition.cpp:2417: [72075186224037892][Partition][0][StateIdle] Events: 0, PendingCommits: 0, PendingWrites: 0
2026-03-17T14:16:28.605865Z node 17 :PERSQUEUE DEBUG: partition.cpp:2376: [72075186224037892][Partition][0][StateIdle] Try persist
