2025-10-26T18:07:25.885105Z node 12 :METADATA_PROVIDER WARN: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[12:7565593676620644180:4098];send_to=[0:7307199536658146131:7762515];
2025-10-26T18:07:25.886052Z node 12 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:68;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-10-26T18:07:25.951268Z node 12 :PQ_READ_PROXY DEBUG: Direct read cache created
test_client.cpp: SetPath # /home/runner/.ya/build/build_root/70hy/000519/r3tmp/tmpTCEd6g/pdisk_1.dat
2025-10-26T18:07:26.226188Z node 12 :IMPORT WARN: Table profiles were not loaded
2025-10-26T18:07:26.267658Z node 12 :HIVE WARN: HIVE#72057594037968897 Node(12, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-10-26T18:07:26.267782Z node 12 :HIVE WARN: HIVE#72057594037968897 Node(12, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-10-26T18:07:26.269321Z node 12 :HIVE WARN: HIVE#72057594037968897 Node(12, (0,0,0,0)) VolatileState: Connecting -> Connected
TServer::EnableGrpc on GrpcPort 26580, node 12
2025-10-26T18:07:26.372822Z node 12 :NET_CLASSIFIER WARN: distributable config is empty, broken or outdated, will use file: /home/runner/.ya/build/build_root/70hy/000519/r3tmp/yandexvuadNX.tmp
2025-10-26T18:07:26.372861Z node 12 :NET_CLASSIFIER WARN: will try to initialize from file: /home/runner/.ya/build/build_root/70hy/000519/r3tmp/yandexvuadNX.tmp
2025-10-26T18:07:26.372997Z node 12 :NET_CLASSIFIER WARN: successfully initialized from file: /home/runner/.ya/build/build_root/70hy/000519/r3tmp/yandexvuadNX.tmp
2025-10-26T18:07:26.373139Z node 12 :NET_CLASSIFIER ERROR: got bad distributable configuration
2025-10-26T18:07:26.444225Z INFO: TTestServer started on Port 27005 GrpcPort 26580
TClient is connected to server localhost:27005
PQClient connected to localhost:26580
WaitRootIsUp 'Root'...
TClient::Ls request: Root
TClient::Ls response: Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "Root"
    PathId: 1
    SchemeshardId: 72057594046644480
    PathType: EPathTypeDir
    CreateFinished: true
    CreateTxId: 1
    CreateStep: 0
    ParentPathId: 1
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 1
      SubDomainVersion: 0
      SecurityStateVersion: 0
    }
  }
  Children {
    Name: ".sys"
    PathId: 18446744073709551615
    SchemeshardId: 72057594046644480
    PathType: EPathTypeDir
    CreateFinished: true
    CreateTxId: 0
    CreateStep: 0
    ParentPathId: 18446744073709551615
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 0
      PlanResolution: 7
      Coo...
(TRUNCATED)
WaitRootIsUp 'Root' success.
2025-10-26T18:07:26.747286Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterSubDomain, opId: 281474976710657:0, at schemeshard:  72057594046644480
waiting...
2025-10-26T18:07:26.755652Z node 12 :FLAT_TX_SCHEMESHARD WARN: NotifyTxCompletion, unknown transaction, txId: 281474976710657, at schemeshard: 72057594046644480
waiting...
2025-10-26T18:07:26.768654Z node 12 :FLAT_TX_SCHEMESHARD WARN: NotifyTxCompletion, unknown transaction, txId: 281474976710658, at schemeshard: 72057594046644480
2025-10-26T18:07:26.788908Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710659:0, at schemeshard:  72057594046644480
waiting...
waiting...
2025-10-26T18:07:26.933326Z node 12 :FLAT_TX_SCHEMESHARD WARN: NotifyTxCompletion, unknown transaction, txId: 281474976710660, at schemeshard: 72057594046644480
waiting...
2025-10-26T18:07:26.946315Z node 12 :FLAT_TX_SCHEMESHARD WARN: NotifyTxCompletion, unknown transaction, txId: 281474976710661, at schemeshard: 72057594046644480
2025-10-26T18:07:30.885336Z node 12 :METADATA_PROVIDER ERROR: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[12:7565593676620644180:4098];send_to=[0:7307199536658146131:7762515];
2025-10-26T18:07:30.885479Z node 12 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:68;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2025-10-26T18:07:31.123139Z node 12 :KQP_COMPILE_ACTOR ERROR: Compilation failed, self: [12:7565593702390448679:4286], status: SCHEME_ERROR, issues: <main>: Error: Type annotation, code: 1030
    <main>:3:16: Error: At function: KiReadTable!
        <main>:3:16: Error: Cannot find table 'db.[/Root/PQ/Config/V2/Cluster]' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions., code: 2003
2025-10-26T18:07:31.125673Z node 12 :KQP_SESSION WARN: SessionId: ydb://session/3?node_id=12&id=ZjdkMTJhMTItZjhkM2I1NDMtNWJmMTYxYTUtYTcwM2UzYQ==, ActorId: [12:7565593702390448677:4273], ActorState: ExecuteState, TraceId: 01k8gv8erb5mwffyh75jfks3hy, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-10-26T18:07:31.126436Z node 12 :PERSQUEUE_CLUSTER_TRACKER ERROR: failed to list clusters: { Response { QueryIssues { message: "Type annotation" issue_code: 1030 severity: 1 issues { position { row: 3 column: 16 } message: "At function: KiReadTable!" end_position { row: 3 column: 16 } severity: 1 issues { position { row: 3 column: 16 } message: "Cannot find table \'db.[/Root/PQ/Config/V2/Cluster]\' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions." end_position { row: 3 column: 16 } issue_code: 2003 severity: 1 } } } TxMeta { } } YdbStatus: SCHEME_ERROR ConsumedRu: 1 }
2025-10-26T18:07:31.144278Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710662:0, at schemeshard:  72057594046644480
2025-10-26T18:07:31.194027Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710663:0, at schemeshard:  72057594046644480
2025-10-26T18:07:31.366581Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710664:0, at schemeshard:  72057594046644480
=== 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);
2025-10-26T18:07:31.753103Z node 12 :KQP_EXECUTER ERROR: TxId: 281474976710665. Ctx: { TraceId: 01k8gv8f4x7mx794zksabtmkcg, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=12&id=NTRjNTZmYjQtODc1YzU2ZjYtYmZiYzdkNS1lMGRmMjM0Zg==, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
=== CheckClustersList. Subcribe to ClusterTracker from [12:7565593702390448964:12347] 
=== CheckClustersList. Ok
PQ Client: create topic: rt3.dc1--topic1 with 2 partitions
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:36.927141Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:36.927189Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:36.927215Z node 12 :PQ_METACACHE DEBUG: Describe all topics - send empty response
2025-10-26T18:07:36.927260Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 0 topics
2025-10-26T18:07:36.927353Z node 12 :PERSQUEUE INFO: 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:26580
MetaRequest {
  CmdCreateTopic {
    Topic: "rt3.dc1--topic1"
    NumPartitions: 2
    Config {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user"
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
    }
  }
}
CallPersQueueGRPC response:
Status: 129
ProxyErrorCode: 53
SchemeStatus: 1
FlatTxId {
  TxId: 281474976710674
  SchemeShardTabletId: 72057594046644480
  PathId: 9
}
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
2025-10-26T18:07:36.952383Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic  pipe [12:7565593723865285788:8399] connected; active server actors: 1
2025-10-26T18:07:36.952671Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037893] topic rt3.dc1--topic1 updating configuration. Deleted partitions []. Added partitions [1, 0]
2025-10-26T18:07:36.953290Z node 12 :PERSQUEUE NOTICE: Tablet 72075186224037892 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:07:36.953331Z node 12 :PERSQUEUE INFO: Tablet 72075186224037892 doesn't have tx writes info
2025-10-26T18:07:36.953488Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-10-26T18:07:36.953577Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: BALANCER INIT DONE for rt3.dc1--topic1: (0, 72075186224037892) (1, 72075186224037892) 
2025-10-26T18:07:36.956131Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037893 topic rt3.dc1--topic1 TEvClientConnected TabletId 72075186224037892, NodeId 12, Generation 1
2025-10-26T18:07:36.956154Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037893 topic rt3.dc1--topic1 TEvClientConnected TabletId 72057594046644480, NodeId 12, Generation 2
2025-10-26T18:07:36.962775Z node 12 :PERSQUEUE INFO: bootstrapping 1 [12:7565593723865285851:4286]
2025-10-26T18:07:36.966510Z node 12 :PERSQUEUE INFO: bootstrapping 0 [12:7565593723865285852:4314]
2025-10-26T18:07:36.968716Z node 12 :PERSQUEUE INFO: init complete for topic 'rt3.dc1--topic1' partition 0 generation 1 [12:7565593723865285852:4314]
2025-10-26T18:07:36.971315Z node 12 :PERSQUEUE INFO: init complete for topic 'rt3.dc1--topic1' partition 1 generation 1 [12:7565593723865285851:4286]
2025-10-26T18:07:36.983068Z node 12 :PERSQUEUE NOTICE: Tablet 72075186224037892 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:07:37.059411Z node 12 :PQ_METACACHE DEBUG: Check version rescan
2025-10-26T18:07:37.067571Z node 12 :PQ_METACACHE DEBUG: Got config version: 0
2025-10-26T18:07:37.076367Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:37.076454Z node 12 :PQ_METACACHE DEBUG: Updated topics list with : 0 topics
2025-10-26T18:07:37.076466Z node 12 :PQ_METACACHE DEBUG: Metacache: reset
2025-10-26T18:07:37.171019Z node 12 :KQP_EXECUTER ERROR: TxId: 281474976710677. Ctx: { TraceId: 01k8gv8mgf6049qpgazdrdt7mg, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=12&id=ZTk5MTZkZTktYWMyZTRkY2YtZDAwMzY0ZmYtNzE4ZDMwNw==, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
===Query complete
TClient::Ls request: /Root/PQ/rt3.dc1--topic1
TClient::Ls response: Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--topic1"
    PathId: 9
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710674
    CreateStep: 1761502057007
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    BalancerTabletID: 72075186224037893
  }
  PersQueueGroup {
    Name: "rt3.dc1--topic1"
    PathId: 9
    TotalGroupCount: 2
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxC...
(TRUNCATED)
GetTopicVersionFromPath:  record Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--topic1"
    PathId: 9
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710674
    CreateStep: 1761502057007
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    BalancerTabletID: 72075186224037893
  }
  PersQueueGroup {
    Name: "rt3.dc1--topic1"
    PathId: 9
    TotalGroupCount: 2
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user"
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
      YdbDatabasePath: "/Root"
    }
    Partitions {
      PartitionId: 0
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 1
      TabletId: 72075186224037892
      Status: Active
    }
    AlterVersion: 1
    BalancerTabletID: 72075186224037893
    NextPartitionId: 2
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 1
      PlanResolution: 7
      Coordinators: 72057594046316545
      TimeCastBucketsPerMediator: 2
      Mediators: 72057594046382081
    }
    DomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    PathsInside: 8
    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: 2
    PQPartitionsLimit: 1000000
  }
}
Path: "/Root/PQ/rt3.dc1--topic1"
 name rt3.dc1--topic1 version1
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:37.218856Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:37.218889Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:37.218898Z node 12 :PQ_METACACHE DEBUG: Describe all topics - send empty response
2025-10-26T18:07:37.218911Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 0 topics
2025-10-26T18:07:37.218958Z node 12 :PERSQUEUE INFO: 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:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:37.727314Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:37.727346Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:37.727358Z node 12 :PQ_METACACHE DEBUG: Describe all topics - send empty response
2025-10-26T18:07:37.727375Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 0 topics
2025-10-26T18:07:37.727433Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--topic1, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
2025-10-26T18:07:38.076902Z node 12 :PQ_METACACHE DEBUG: Check version rescan
2025-10-26T18:07:38.088223Z node 12 :PQ_METACACHE DEBUG: Got config version: 1
2025-10-26T18:07:38.098764Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:38.108547Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:38.108700Z node 12 :PQ_METACACHE DEBUG: Updated topics list with : 1 topics
2025-10-26T18:07:38.108710Z node 12 :PQ_METACACHE DEBUG: Metacache: reset
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:38.232982Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:38.233012Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:38.233025Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics SendSchemeCacheRequest
2025-10-26T18:07:38.233045Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:38.233139Z node 12 :PQ_METACACHE DEBUG: send request for  all 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:38.235113Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 2 ResultSet [{ Path: Root/PQ/rt3.dc1--topic1 TableId: [72057594046644480:9:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: false Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:38.235139Z node 12 :PQ_METACACHE DEBUG: Got describe all topics SC response
2025-10-26T18:07:38.235312Z node 12 :PQ_METACACHE DEBUG: Updated topics cache with 1
2025-10-26T18:07:38.235331Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 1 topics
2025-10-26T18:07:38.235663Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetTopicMetadataResult {
    TopicInfo {
      Topic: "rt3.dc1--topic1"
      NumPartitions: 2
      Config {
        PartitionConfig {
          LifetimeSeconds: 86400
          LowWatermark: 8388608
          SourceIdLifetimeSeconds: 86400
          WriteSpeedInBytesPerSecond: 20000000
          BurstSize: 20000000
          SourceIdMaxCounts: 6000000
        }
        Version: 1
        LocalDC: true
        ReadRules: "user"
        ReadFromTimestampsMs: 0
        ConsumerFormatVersions: 0
        ConsumerCodecs {
        }
        Codecs {
          Ids: 0
          Ids: 1
          Ids: 2
          Codecs: "raw"
          Codecs: "gzip"
          Codecs: "lzop"
        }
        ReadRuleVersions: 0
        TopicPath: "/Root/PQ/rt3.dc1--topic1"
        YdbDatabasePath: "/Root"
        Consumers {
          Name: "user"
          ReadFromTimestampsMs: 0
          FormatVersion: 0
          Codec {
          }
          Version: 0
        ...
(TRUNCATED)
=== Topic created, have version: 1
PQ Client: create topic: rt3.dc1--topic12 with 1 partitions
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic12"
  }
}
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--topic12, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdCreateTopic {
    Topic: "rt3.dc1--topic12"
    NumPartitions: 1
    Config {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user1"
      ReadRules: "user2"
      ReadFromTimestampsMs: 0
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
      ReadRuleVersions: 0
    }
  }
}
2025-10-26T18:07:38.244096Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:38.244123Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:38.244136Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:38.244158Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 1 topics
2025-10-26T18:07:38.244218Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 129
ProxyErrorCode: 53
SchemeStatus: 1
FlatTxId {
  TxId: 281474976710681
  SchemeShardTabletId: 72057594046644480
  PathId: 10
}
ErrorCode: OK
AddTopic: rt3.dc1--topic12
===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 = topic12, dc = dc1
2025-10-26T18:07:38.284012Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic  pipe [12:7565593732455220690:8458] connected; active server actors: 1
2025-10-26T18:07:38.284340Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 updating configuration. Deleted partitions []. Added partitions [0]
2025-10-26T18:07:38.287252Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
2025-10-26T18:07:38.287389Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: BALANCER INIT DONE for rt3.dc1--topic12: (0, 72075186224037894) 
2025-10-26T18:07:38.288082Z node 12 :PERSQUEUE NOTICE: Tablet 72075186224037894 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:07:38.288130Z node 12 :PERSQUEUE INFO: Tablet 72075186224037894 doesn't have tx writes info
2025-10-26T18:07:38.291100Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037895 topic rt3.dc1--topic12 TEvClientConnected TabletId 72075186224037894, NodeId 12, Generation 1
2025-10-26T18:07:38.291127Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037895 topic rt3.dc1--topic12 TEvClientConnected TabletId 72057594046644480, NodeId 12, Generation 2
2025-10-26T18:07:38.305145Z node 12 :PERSQUEUE INFO: bootstrapping 0 [12:7565593732455220723:4346]
2025-10-26T18:07:38.308858Z node 12 :PERSQUEUE INFO: init complete for topic 'rt3.dc1--topic12' partition 0 generation 1 [12:7565593732455220723:4346]
2025-10-26T18:07:38.316213Z node 12 :PQ_METACACHE DEBUG: HandleClustersUpdate
2025-10-26T18:07:38.316246Z node 12 :PQ_METACACHE DEBUG: HandleClustersUpdate LocalCluster !LocalCluster.empty()
2025-10-26T18:07:38.319191Z node 12 :PERSQUEUE NOTICE: Tablet 72075186224037894 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:07:38.492346Z node 12 :KQP_EXECUTER ERROR: TxId: 281474976710683. Ctx: { TraceId: 01k8gv8nt5463b4x1gtdd2j54p, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=12&id=YzEyODVlYzYtNTk1YTlkMGYtNTAzNzI2MDYtMmYwZTIwNjQ=, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
===Query complete
TClient::Ls request: /Root/PQ/rt3.dc1--topic12
TClient::Ls response: Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--topic12"
    PathId: 10
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710681
    CreateStep: 1761502058344
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    BalancerTabletID: 72075186224037895
  }
  PersQueueGroup {
    Name: "rt3.dc1--topic12"
    PathId: 10
    TotalGroupCount: 1
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceId...
(TRUNCATED)
GetTopicVersionFromPath:  record Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--topic12"
    PathId: 10
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710681
    CreateStep: 1761502058344
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    BalancerTabletID: 72075186224037895
  }
  PersQueueGroup {
    Name: "rt3.dc1--topic12"
    PathId: 10
    TotalGroupCount: 1
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user1"
      ReadRules: "user2"
      ReadFromTimestampsMs: 0
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
      ReadRuleVersions: 0
      YdbDatabasePath: "/Root"
    }
    Partitions {
      PartitionId: 0
      TabletId: 72075186224037894
      Status: Active
    }
    AlterVersion: 1
    BalancerTabletID: 72075186224037895
    NextPartitionId: 1
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 1
      PlanResolution: 7
      Coordinators: 72057594046316545
      TimeCastBucketsPerMediator: 2
      Mediators: 72057594046382081
    }
    DomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    PathsInside: 9
    PathsLimit: 10000
    ShardsInside: 8
    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
  }
}
Path: "/Root/PQ/rt3.dc1--topic12"
 name rt3.dc1--topic12 version1
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic12"
  }
}
2025-10-26T18:07:38.521312Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:38.521342Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:38.521351Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:38.521368Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 1 topics
2025-10-26T18:07:38.521451Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--topic12, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic12"
  }
}
2025-10-26T18:07:39.025339Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:39.025373Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:39.025385Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:39.025403Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 1 topics
2025-10-26T18:07:39.025479Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--topic12, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
2025-10-26T18:07:39.108940Z node 12 :PQ_METACACHE DEBUG: Check version rescan
2025-10-26T18:07:39.123498Z node 12 :PQ_METACACHE DEBUG: Got config version: 2
2025-10-26T18:07:39.134920Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:39.144764Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:39.145148Z node 12 :PQ_METACACHE DEBUG: Updated topics list with : 2 topics
2025-10-26T18:07:39.145159Z node 12 :PQ_METACACHE DEBUG: Metacache: reset
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--topic12"
  }
}
2025-10-26T18:07:39.530604Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:39.530635Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:39.530646Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics SendSchemeCacheRequest
2025-10-26T18:07:39.530662Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:39.530754Z node 12 :PQ_METACACHE DEBUG: send request for  all 2 topics, got 1 requests infly, db = ""
2025-10-26T18:07:39.532615Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 3 ResultSet [{ Path: Root/PQ/rt3.dc1--topic1 TableId: [72057594046644480:9:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: false Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } },{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: false Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:39.532647Z node 12 :PQ_METACACHE DEBUG: Got describe all topics SC response
2025-10-26T18:07:39.532939Z node 12 :PQ_METACACHE DEBUG: Updated topics cache with 2
2025-10-26T18:07:39.532956Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:39.533312Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetTopicMetadataResult {
    TopicInfo {
      Topic: "rt3.dc1--topic12"
      NumPartitions: 1
      Config {
        PartitionConfig {
          LifetimeSeconds: 86400
          LowWatermark: 8388608
          SourceIdLifetimeSeconds: 86400
          WriteSpeedInBytesPerSecond: 20000000
          BurstSize: 20000000
          SourceIdMaxCounts: 6000000
        }
        Version: 1
        LocalDC: true
        ReadRules: "user1"
        ReadRules: "user2"
        ReadFromTimestampsMs: 0
        ReadFromTimestampsMs: 0
        ConsumerFormatVersions: 0
        ConsumerFormatVersions: 0
        ConsumerCodecs {
        }
        ConsumerCodecs {
        }
        Codecs {
          Ids: 0
          Ids: 1
          Ids: 2
          Codecs: "raw"
          Codecs: "gzip"
          Codecs: "lzop"
        }
        ReadRuleVersions: 0
        ReadRuleVersions: 0
        TopicPath: "/Root/PQ/rt3.dc1--topic12"
        YdbDatabasePath: "/Root"
    ...
(TRUNCATED)
=== Topic created, have version: 1
2025-10-26T18:07:39.549652Z :DEBUG: [] MessageGroupId [src] SessionId [] Write session: try to update token
2025-10-26T18:07:39.550523Z :INFO: [] MessageGroupId [src] SessionId [] Write session: Do CDS request
2025-10-26T18:07:39.550577Z :INFO: [] MessageGroupId [src] SessionId [] Start write session. Will connect to endpoint: localhost:26580
2025-10-26T18:07:39.563683Z :DEBUG: [] MessageGroupId [src] SessionId [] Write session: send init request: init_request { topic: "topic12" message_group_id: "src" }
2025-10-26T18:07:39.572437Z node 12 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-10-26T18:07:39.572481Z node 12 :PQ_WRITE_PROXY DEBUG: new session created cookie 1
2025-10-26T18:07:39.574150Z node 12 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 1 sessionId:  grpc read done: success: 1 data: init_request { topic: "topic12" message_group_id: "src" }
2025-10-26T18:07:39.574300Z node 12 :PQ_WRITE_PROXY INFO: session request cookie: 1 topic: "topic12" message_group_id: "src" from ipv6:[::1]:51330
2025-10-26T18:07:39.574320Z node 12 :PQ_WRITE_PROXY INFO: write session:  cookie=1 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:51330 proto=v1  topic=topic12 durationSec=0
2025-10-26T18:07:39.574331Z node 12 :PQ_WRITE_PROXY INFO: init check schema
2025-10-26T18:07:39.574588Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:39.574614Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:39.574686Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:39.575188Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 4 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:39.575292Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:39.576956Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId:  describe result for acl check
2025-10-26T18:07:39.577157Z node 12 :PQ_PARTITION_CHOOSER DEBUG: 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;
2025-10-26T18:07:39.577172Z node 12 :PQ_PARTITION_CHOOSER DEBUG: 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);
2025-10-26T18:07:39.577192Z node 12 :PQ_PARTITION_CHOOSER DEBUG: 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;
2025-10-26T18:07:39.577218Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) StartKqpSession
2025-10-26T18:07:39.581573Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) Select from the table
2025-10-26T18:07:39.800096Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) RequestPQRB
2025-10-26T18:07:39.800617Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593736750188245:4319] connected; active server actors: 1
2025-10-26T18:07:39.800776Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) Received partition 0 from PQRB for SourceId=src
2025-10-26T18:07:39.800806Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) Update the table
2025-10-26T18:07:39.801491Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593736750188245:4319] disconnected; active server actors: 1
2025-10-26T18:07:39.801522Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593736750188245:4319] disconnected no session
2025-10-26T18:07:39.867928Z node 12 :PQ_METACACHE DEBUG: HandleClustersUpdate
2025-10-26T18:07:39.867959Z node 12 :PQ_METACACHE DEBUG: HandleClustersUpdate LocalCluster !LocalCluster.empty()
2025-10-26T18:07:39.957676Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) HandleUpdate PartitionPersisted=0 Status=SUCCESS
2025-10-26T18:07:39.957751Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=(NULL)
2025-10-26T18:07:39.957783Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593736750188192:4319] (SourceId=src, PreferedPartition=(NULL)) Start idle
2025-10-26T18:07:39.957823Z node 12 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 1 sessionId:  partition: 0 expectedGeneration: (NULL)
2025-10-26T18:07:39.959672Z node 12 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 12, Generation: 1
2025-10-26T18:07:39.959984Z node 12 :PERSQUEUE INFO: new Cookie src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0 generated for partition 0 topic 'rt3.dc1--topic12' owner src
2025-10-26T18:07:39.960617Z node 12 :PQ_WRITE_PROXY INFO: session inited cookie: 1 partition: 0 MaxSeqNo: 0 sessionId: src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0
2025-10-26T18:07:39.961842Z :INFO: [] MessageGroupId [src] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1761502059961 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-10-26T18:07:39.961985Z :INFO: [] MessageGroupId [src] SessionId [] Write session established. Init response: session_id: "src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0" topic: "topic12" cluster: "dc1" supported_codecs: CODEC_RAW supported_codecs: CODEC_GZIP supported_codecs: CODEC_LZOP
2025-10-26T18:07:39.962341Z :INFO: [] MessageGroupId [src] SessionId [src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0] Write session: close. Timeout = 0 ms
2025-10-26T18:07:39.962411Z :INFO: [] MessageGroupId [src] SessionId [src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0] Write session will now close
2025-10-26T18:07:39.962471Z :DEBUG: [] MessageGroupId [src] SessionId [src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0] Write session: aborting
2025-10-26T18:07:39.963083Z :INFO: [] MessageGroupId [src] SessionId [src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0] Write session: gracefully shut down, all writes complete
2025-10-26T18:07:39.963126Z :DEBUG: [] MessageGroupId [src] SessionId [src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0] Write session: destroy
2025-10-26T18:07:39.963985Z node 12 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 1 sessionId: src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0 grpc read done: success: 0 data: 
2025-10-26T18:07:39.964006Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0 grpc read failed
2025-10-26T18:07:39.964036Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0 grpc closed
2025-10-26T18:07:39.964060Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|f13622d0-b8cbc00e-7a4de6dd-a5e17dd2_0 is DEAD
2025-10-26T18:07:39.964911Z node 12 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-10-26T18:07:40.061651Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710690:1, at schemeshard:  72057594046644480
2025-10-26T18:07:40.144747Z node 12 :PQ_METACACHE DEBUG: Check version rescan
2025-10-26T18:07:40.153211Z node 12 :PQ_METACACHE DEBUG: Metacache: reset
2025-10-26T18:07:40.214740Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710692:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.363798Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710693:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.436021Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710694:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.444119Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710695:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.452007Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710696:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.459941Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710697:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.464572Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710698:0, at schemeshard:  72057594046644480
2025-10-26T18:07:40.475501Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710699:0, at schemeshard:  72057594046644480
=== Create writer
2025-10-26T18:07:40.483926Z node 12 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.483971Z node 12 :PQ_WRITE_PROXY DEBUG: new session created cookie 2
2025-10-26T18:07:40.484634Z node 12 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 2 sessionId:  grpc read done: success: 1 data: init_request { topic: "topic1" message_group_id: "12345678" }
2025-10-26T18:07:40.484809Z node 12 :PQ_WRITE_PROXY INFO: session request cookie: 2 topic: "topic1" message_group_id: "12345678" from ipv6:[::1]:33926
2025-10-26T18:07:40.484844Z node 12 :PQ_WRITE_PROXY INFO: write session:  cookie=2 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:33926 proto=v1  topic=topic1 durationSec=0
2025-10-26T18:07:40.484860Z node 12 :PQ_WRITE_PROXY INFO: init check schema
2025-10-26T18:07:40.485068Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.485097Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.485172Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.485803Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 5 ResultSet [{ Path: Root/PQ/rt3.dc1--topic1 TableId: [72057594046644480:9:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.487692Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.489274Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId:  describe result for acl check
2025-10-26T18:07:40.489483Z node 12 :PQ_PARTITION_CHOOSER DEBUG: 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;
2025-10-26T18:07:40.489504Z node 12 :PQ_PARTITION_CHOOSER DEBUG: 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);
2025-10-26T18:07:40.489527Z node 12 :PQ_PARTITION_CHOOSER DEBUG: 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;
2025-10-26T18:07:40.489553Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) StartKqpSession
2025-10-26T18:07:40.493767Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) Select from the table
2025-10-26T18:07:40.503482Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) RequestPQRB
2025-10-26T18:07:40.503990Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155907:4344] connected; active server actors: 1
2025-10-26T18:07:40.504211Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) Received partition 0 from PQRB for SourceId=12345678
2025-10-26T18:07:40.504252Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) Update the table
2025-10-26T18:07:40.504797Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155907:4344] disconnected; active server actors: 1
2025-10-26T18:07:40.504834Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155907:4344] disconnected no session
2025-10-26T18:07:40.511969Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) HandleUpdate PartitionPersisted=0 Status=SUCCESS
2025-10-26T18:07:40.512026Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=(NULL)
2025-10-26T18:07:40.512054Z node 12 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [12:7565593741045155892:4344] (SourceId=12345678, PreferedPartition=(NULL)) Start idle
2025-10-26T18:07:40.512096Z node 12 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 2 sessionId:  partition: 0 expectedGeneration: (NULL)
2025-10-26T18:07:40.512787Z node 12 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037892 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037892, NodeId 12, Generation: 1
2025-10-26T18:07:40.513039Z node 12 :PERSQUEUE INFO: new Cookie 12345678|773083ad-a9daaa1-48f16d46-74a9da60_0 generated for partition 0 topic 'rt3.dc1--topic1' owner 12345678
2025-10-26T18:07:40.513580Z node 12 :PQ_WRITE_PROXY INFO: session inited cookie: 2 partition: 0 MaxSeqNo: 0 sessionId: 12345678|773083ad-a9daaa1-48f16d46-74a9da60_0
2025-10-26T18:07:40.518111Z node 12 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 2 sessionId: 12345678|773083ad-a9daaa1-48f16d46-74a9da60_0 grpc read done: success: 0 data: 
2025-10-26T18:07:40.518134Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId: 12345678|773083ad-a9daaa1-48f16d46-74a9da60_0 grpc read failed
2025-10-26T18:07:40.518341Z node 12 :PQ_WRITE_PROXY INFO: session v1 closed cookie: 2 sessionId: 12345678|773083ad-a9daaa1-48f16d46-74a9da60_0
2025-10-26T18:07:40.518366Z node 12 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId: 12345678|773083ad-a9daaa1-48f16d46-74a9da60_0 is DEAD
Finish: 0 
2025-10-26T18:07:40.518811Z node 12 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037892 (partition=0) Received event: NActors::TEvents::TEvPoison
BEFORE MODIFY PERMISSIONS
2025-10-26T18:07:40.537814Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710702:0, at schemeshard:  72057594046644480
=== Writer - do reads
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.544462Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.544495Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 1
2025-10-26T18:07:40.544867Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.544885Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.544894Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.544907Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.545329Z node 12 :PQ_READ_PROXY DEBUG: session cookie 1 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.545540Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155934:8442] connected; active server actors: 1
2025-10-26T18:07:40.545799Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.545934Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.546134Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155934:8442] disconnected; active server actors: 1
2025-10-26T18:07:40.546169Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155934:8442] disconnected no session
2025-10-26T18:07:40.546420Z node 12 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 auth for : user1
2025-10-26T18:07:40.546481Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
CallPersQueueGRPC response:
2025-10-26T18:07:40.546496Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.546551Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.547053Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 6 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.547162Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.547265Z node 12 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 Handle describe topics response
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.547535Z node 12 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 Send client acl request
=== Got response: status: SUCCESS init_response { session_id: "shared/user1_12_1_5806843027559687444_v1" }
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.549846Z node 12 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 auth is DEAD
2025-10-26T18:07:40.549939Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 auth ok: topics# 1, initDone# 0
2025-10-26T18:07:40.551109Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 register session: topic# rt3.dc1--topic12
2025-10-26T18:07:40.551639Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045155949:4327] connected; active server actors: 1
2025-10-26T18:07:40.551753Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer "user1" register session for pipe [12:7565593741045155949:4327] session shared/user1_12_1_5806843027559687444_v1
2025-10-26T18:07:40.551841Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 register readable partition 0
2025-10-26T18:07:40.551930Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 family created family=1 (Status=Free, Partitions=[0])
2025-10-26T18:07:40.552006Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 register reading session ReadingSession "shared/user1_12_1_5806843027559687444_v1" (Sender=[12:7565593741045155931:4327], Pipe=[12:7565593741045155949:4327], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.552058Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 rebalancing was scheduled
2025-10-26T18:07:40.552149Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 balancing. Sessions=1, Families=1, UnradableFamilies=1 [1 (0), ], RequireBalancing=0 []
2025-10-26T18:07:40.552240Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 balancing family=1 (Status=Free, Partitions=[0]) for ReadingSession "shared/user1_12_1_5806843027559687444_v1" (Sender=[12:7565593741045155931:4327], Pipe=[12:7565593741045155949:4327], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.552339Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 family 1 status Active partitions [0] session "shared/user1_12_1_5806843027559687444_v1" sender [12:7565593741045155931:4327] lock partition 0 for ReadingSession "shared/user1_12_1_5806843027559687444_v1" (Sender=[12:7565593741045155931:4327], Pipe=[12:7565593741045155949:4327], Partitions=[], ActiveFamilyCount=1) generation 1 step 1
2025-10-26T18:07:40.552430Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 start rebalancing. familyCount=1, sessionCount=1, desiredFamilyCount=1, allowPlusOne=0
2025-10-26T18:07:40.552493Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 balancing duration: 0.000293s
2025-10-26T18:07:40.553782Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 assign: record# { Partition: 0 TabletId: 72075186224037894 Topic: "rt3.dc1--topic12" Generation: 1 Step: 1 Session: "shared/user1_12_1_5806843027559687444_v1" ClientId: "user1" PipeClient { RawX1: 7565593741045155949 RawX2: 4503651166982375 } Path: "/Root/PQ/rt3.dc1--topic12" }
2025-10-26T18:07:40.553943Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 INITING TopicId: Topic rt3.dc1--topic12 in dc dc1 in database: Root, partition 0(assignId:1)
2025-10-26T18:07:40.554269Z node 12 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 grpc read done: success# 0, data# {  }
2025-10-26T18:07:40.554306Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 grpc read failed
2025-10-26T18:07:40.554342Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 grpc closed
2025-10-26T18:07:40.554385Z node 12 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user1 session shared/user1_12_1_5806843027559687444_v1 is DEAD
2025-10-26T18:07:40.555524Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.555542Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.555548Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.555572Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.556314Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.556327Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 2
2025-10-26T18:07:40.556485Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155957:8529] connected; active server actors: 1
2025-10-26T18:07:40.556656Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045155949:4327] disconnected; active server actors: 1
2025-10-26T18:07:40.556715Z node 12 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user1_12_1_5806843027559687444_v1:1 with generation 1
2025-10-26T18:07:40.556722Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045155949:4327] client user1 disconnected session shared/user1_12_1_5806843027559687444_v1
2025-10-26T18:07:40.556804Z node 12 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user1_12_1_5806843027559687444_v1
2025-10-26T18:07:40.557306Z node 12 :PQ_READ_PROXY DEBUG: session cookie 2 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.557458Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.557524Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.557647Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155957:8529] disconnected; active server actors: 1
2025-10-26T18:07:40.557675Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155957:8529] disconnected no session
2025-10-26T18:07:40.557929Z node 12 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 auth for : user1
2025-10-26T18:07:40.557981Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.557997Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.558076Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
CallPersQueueGRPC response:
2025-10-26T18:07:40.558684Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 7 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.558792Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.558951Z node 12 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 Handle describe topics response
2025-10-26T18:07:40.559101Z node 12 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 Send client acl request
2025-10-26T18:07:40.559531Z node 12 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 auth is DEAD
2025-10-26T18:07:40.559546Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 auth ok: topics# 1, initDone# 0
=== Got response: 2025-10-26T18:07:40.561049Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 register session: topic# rt3.dc1--topic12
status: SUCCESS init_response { session_id: "shared/user1_12_2_5179324843327143555_v1" }
2025-10-26T18:07:40.561611Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045155968:4369] connected; active server actors: 1
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.561859Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer "user1" register session for pipe [12:7565593741045155968:4369] session shared/user1_12_2_5179324843327143555_v1
2025-10-26T18:07:40.561907Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 register readable partition 0
2025-10-26T18:07:40.561957Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 family created family=1 (Status=Free, Partitions=[0])
2025-10-26T18:07:40.561991Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 register reading session ReadingSession "shared/user1_12_2_5179324843327143555_v1" (Sender=[12:7565593741045155961:4369], Pipe=[12:7565593741045155968:4369], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.562027Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 rebalancing was scheduled
2025-10-26T18:07:40.562090Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 balancing. Sessions=1, Families=1, UnradableFamilies=1 [1 (0), ], RequireBalancing=0 []
2025-10-26T18:07:40.562132Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 balancing family=1 (Status=Free, Partitions=[0]) for ReadingSession "shared/user1_12_2_5179324843327143555_v1" (Sender=[12:7565593741045155961:4369], Pipe=[12:7565593741045155968:4369], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.562179Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 family 1 status Active partitions [0] session "shared/user1_12_2_5179324843327143555_v1" sender [12:7565593741045155961:4369] lock partition 0 for ReadingSession "shared/user1_12_2_5179324843327143555_v1" (Sender=[12:7565593741045155961:4369], Pipe=[12:7565593741045155968:4369], Partitions=[], ActiveFamilyCount=1) generation 1 step 2
2025-10-26T18:07:40.562231Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 start rebalancing. familyCount=1, sessionCount=1, desiredFamilyCount=1, allowPlusOne=0
2025-10-26T18:07:40.562259Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 balancing duration: 0.000148s
2025-10-26T18:07:40.563086Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 assign: record# { Partition: 0 TabletId: 72075186224037894 Topic: "rt3.dc1--topic12" Generation: 1 Step: 2 Session: "shared/user1_12_2_5179324843327143555_v1" ClientId: "user1" PipeClient { RawX1: 7565593741045155968 RawX2: 4503651166982417 } Path: "/Root/PQ/rt3.dc1--topic12" }
2025-10-26T18:07:40.563173Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 INITING TopicId: Topic rt3.dc1--topic12 in dc dc1 in database: Root, partition 0(assignId:1)
2025-10-26T18:07:40.563376Z node 12 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 grpc read done: success# 0, data# {  }
2025-10-26T18:07:40.563393Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 grpc read failed
2025-10-26T18:07:40.563419Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 grpc closed
2025-10-26T18:07:40.563448Z node 12 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user1 session shared/user1_12_2_5179324843327143555_v1 is DEAD
2025-10-26T18:07:40.564183Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.564201Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 3
2025-10-26T18:07:40.564397Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.564400Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045155968:4369] disconnected; active server actors: 1
2025-10-26T18:07:40.564406Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.564414Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045155968:4369] client user1 disconnected session shared/user1_12_2_5179324843327143555_v1
2025-10-26T18:07:40.564414Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.564432Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.564609Z node 12 :PQ_READ_PROXY DEBUG: session cookie 3 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.564839Z node 12 :PQ_READ_PROXY INFO: session cookie 3 consumer shared/user1 session shared/user1_12_3_7975290867726840351_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.564858Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155977:8456] connected; active server actors: 1
2025-10-26T18:07:40.565104Z node 12 :PQ_READ_PROXY DEBUG: session cookie 3 consumer shared/user1 session shared/user1_12_3_7975290867726840351_v1 auth for : user1
CallPersQueueGRPC response:
2025-10-26T18:07:40.565821Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.565839Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.565889Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.565895Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.566023Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155977:8456] disconnected; active server actors: 1
2025-10-26T18:07:40.566069Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155977:8456] disconnected no session
2025-10-26T18:07:40.566503Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 8 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.566614Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.566693Z node 12 :PQ_READ_PROXY DEBUG: session cookie 3 consumer shared/user1 session shared/user1_12_3_7975290867726840351_v1 Handle describe topics response
2025-10-26T18:07:40.566812Z node 12 :PQ_READ_PROXY DEBUG: session cookie 3 consumer shared/user1 session shared/user1_12_3_7975290867726840351_v1 auth is DEAD
2025-10-26T18:07:40.566891Z node 12 :PQ_READ_PROXY INFO: session cookie 3 consumer shared/user1 session shared/user1_12_3_7975290867726840351_v1 closed with error: reason# No ReadTopic permissions for '/Root/PQ/rt3.dc1--topic12' for subject 'user3@builtin'
=== Got response: status: UNAUTHORIZED issues { message: "No ReadTopic permissions for \'/Root/PQ/rt3.dc1--topic12\' for subject \'user3@builtin\'" issue_code: 500018 severity: 1 }
2025-10-26T18:07:40.567201Z node 12 :PQ_READ_PROXY INFO: session cookie 3 consumer shared/user1 session shared/user1_12_3_7975290867726840351_v1 is DEAD
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.569882Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.569903Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 4
2025-10-26T18:07:40.569919Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.569935Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.569945Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.569960Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.570481Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155988:8513] connected; active server actors: 1
2025-10-26T18:07:40.570542Z node 12 :PQ_READ_PROXY DEBUG: session cookie 4 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.570771Z node 12 :PQ_READ_PROXY INFO: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.570912Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.571096Z node 12 :PQ_READ_PROXY DEBUG: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 auth for : user1
2025-10-26T18:07:40.571132Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.571149Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.571208Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.571354Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155988:8513] disconnected; active server actors: 1
2025-10-26T18:07:40.571383Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045155988:8513] disconnected no session
2025-10-26T18:07:40.571736Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 9 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.571860Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.571935Z node 12 :PQ_READ_PROXY DEBUG: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 Handle describe topics response
2025-10-26T18:07:40.572106Z node 12 :PQ_READ_PROXY DEBUG: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 Send client acl request
2025-10-26T18:07:40.572523Z node 12 :PQ_READ_PROXY DEBUG: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 auth is DEAD
2025-10-26T18:07:40.572529Z node 12 :PQ_READ_PROXY INFO: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 closed with error: reason# No ReadAsConsumer permissions for '/Root/PQ/shared/user1' for subject 'user1@builtin'
2025-10-26T18:07:40.572805Z node 12 :PQ_READ_PROXY INFO: session cookie 4 consumer shared/user1 session shared/user1_12_4_18331131550911958071_v1 is DEAD
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
=== Got response: status: UNAUTHORIZED issues { message: "No ReadAsConsumer permissions for \'/Root/PQ/shared/user1\' for subject \'user1@builtin\'" issue_code: 500018 severity: 1 }
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user2" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user2"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.581827Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.581860Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.581869Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.581886Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.582417Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.582439Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 5
2025-10-26T18:07:40.582540Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156001:8554] connected; active server actors: 1
2025-10-26T18:07:40.583108Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.583581Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156001:8554] disconnected; active server actors: 1
2025-10-26T18:07:40.583620Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156001:8554] disconnected no session
2025-10-26T18:07:40.586024Z node 12 :PQ_READ_PROXY DEBUG: session cookie 5 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user2" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.586305Z node 12 :PQ_READ_PROXY INFO: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user2" read_params { max_read_messages_count: 1 } } }
CallPersQueueGRPC response:
2025-10-26T18:07:40.586672Z node 12 :PQ_READ_PROXY DEBUG: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 auth for : user2
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.586844Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.586871Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.586954Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.587512Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 10 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.587611Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.587714Z node 12 :PQ_READ_PROXY DEBUG: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 Handle describe topics response
2025-10-26T18:07:40.587883Z node 12 :PQ_READ_PROXY DEBUG: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 Send client acl request
2025-10-26T18:07:40.589954Z node 12 :PQ_READ_PROXY DEBUG: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 auth is DEAD
2025-10-26T18:07:40.590059Z node 12 :PQ_READ_PROXY INFO: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 closed with error: reason# No ReadAsConsumer permissions for '/Root/PQ/shared/user2' for subject '1@builtin'
2025-10-26T18:07:40.590432Z node 12 :PQ_READ_PROXY INFO: session cookie 5 consumer shared/user2 session shared/user2_12_5_13654734096199624562_v1 is DEAD
=== Got response: status: UNAUTHORIZED issues { message: "No ReadAsConsumer permissions for \'/Root/PQ/shared/user2\' for subject \'1@builtin\'" issue_code: 500018 severity: 1 }
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user2" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user2"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.597701Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.597726Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.597736Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.597753Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.597839Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.597850Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 6
2025-10-26T18:07:40.598214Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156021:8469] connected; active server actors: 1
2025-10-26T18:07:40.598466Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.598579Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156021:8469] disconnected; active server actors: 1
2025-10-26T18:07:40.598615Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156021:8469] disconnected no session
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.601997Z node 12 :PQ_READ_PROXY DEBUG: session cookie 6 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user2" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.602283Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user2" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.602624Z node 12 :PQ_READ_PROXY DEBUG: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 auth for : user2
2025-10-26T18:07:40.602755Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.602783Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.602844Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.603471Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 11 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.603591Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.603650Z node 12 :PQ_READ_PROXY DEBUG: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 Handle describe topics response
2025-10-26T18:07:40.603778Z node 12 :PQ_READ_PROXY DEBUG: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 Send client acl request
2025-10-26T18:07:40.604177Z node 12 :PQ_READ_PROXY DEBUG: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 auth is DEAD
2025-10-26T18:07:40.604181Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 auth ok: topics# 1, initDone# 0
2025-10-26T18:07:40.604975Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 register session: topic# rt3.dc1--topic12
=== Got response: status: SUCCESS init_response { session_id: "shared/user2_12_6_74465489718884182_v1" }
2025-10-26T18:07:40.605462Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045156030:4351] connected; active server actors: 1
2025-10-26T18:07:40.605604Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer "user2" register session for pipe [12:7565593741045156030:4351] session shared/user2_12_6_74465489718884182_v1
2025-10-26T18:07:40.605646Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 register readable partition 0
2025-10-26T18:07:40.605710Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 family created family=1 (Status=Free, Partitions=[0])
2025-10-26T18:07:40.605747Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 register reading session ReadingSession "shared/user2_12_6_74465489718884182_v1" (Sender=[12:7565593741045156019:4351], Pipe=[12:7565593741045156030:4351], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.605770Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 rebalancing was scheduled
2025-10-26T18:07:40.605814Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 balancing. Sessions=1, Families=1, UnradableFamilies=1 [1 (0), ], RequireBalancing=0 []
2025-10-26T18:07:40.605860Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 balancing family=1 (Status=Free, Partitions=[0]) for ReadingSession "shared/user2_12_6_74465489718884182_v1" (Sender=[12:7565593741045156019:4351], Pipe=[12:7565593741045156030:4351], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.605923Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 family 1 status Active partitions [0] session "shared/user2_12_6_74465489718884182_v1" sender [12:7565593741045156019:4351] lock partition 0 for ReadingSession "shared/user2_12_6_74465489718884182_v1" (Sender=[12:7565593741045156019:4351], Pipe=[12:7565593741045156030:4351], Partitions=[], ActiveFamilyCount=1) generation 1 step 3
2025-10-26T18:07:40.605977Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 start rebalancing. familyCount=1, sessionCount=1, desiredFamilyCount=1, allowPlusOne=0
2025-10-26T18:07:40.606003Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user2 balancing duration: 0.000168s
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user5" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user5"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.606603Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 assign: record# { Partition: 0 TabletId: 72075186224037894 Topic: "rt3.dc1--topic12" Generation: 1 Step: 3 Session: "shared/user2_12_6_74465489718884182_v1" ClientId: "user2" PipeClient { RawX1: 7565593741045156030 RawX2: 4503651166982399 } Path: "/Root/PQ/rt3.dc1--topic12" }
2025-10-26T18:07:40.606674Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 INITING TopicId: Topic rt3.dc1--topic12 in dc dc1 in database: Root, partition 0(assignId:1)
2025-10-26T18:07:40.607297Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 TopicId: Topic rt3.dc1--topic12 in dc dc1 in database: Root, partition 0(assignId:1) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037894 Generation: 1
2025-10-26T18:07:40.607507Z node 12 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user2_12_6_74465489718884182_v1:1 with generation 1
2025-10-26T18:07:40.607668Z node 12 :PQ_READ_PROXY DEBUG: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 grpc read done: success# 0, data# {  }
2025-10-26T18:07:40.607692Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 grpc read failed
2025-10-26T18:07:40.607720Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 grpc closed
2025-10-26T18:07:40.607755Z node 12 :PQ_READ_PROXY INFO: session cookie 6 consumer shared/user2 session shared/user2_12_6_74465489718884182_v1 is DEAD
2025-10-26T18:07:40.608756Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045156030:4351] disconnected; active server actors: 1
2025-10-26T18:07:40.608777Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045156030:4351] client user2 disconnected session shared/user2_12_6_74465489718884182_v1
2025-10-26T18:07:40.608821Z node 12 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user2_12_6_74465489718884182_v1
2025-10-26T18:07:40.608967Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.608977Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 7
2025-10-26T18:07:40.609317Z node 12 :PQ_READ_PROXY DEBUG: session cookie 7 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user5" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.609536Z node 12 :PQ_READ_PROXY INFO: session cookie 7 consumer shared/user5 session shared/user5_12_7_7037793843632061402_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user5" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.609640Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.609658Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.609668Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.609700Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.610207Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156042:8516] connected; active server actors: 1
2025-10-26T18:07:40.610362Z node 12 :PQ_READ_PROXY DEBUG: session cookie 7 consumer shared/user5 session shared/user5_12_7_7037793843632061402_v1 auth for : user5
2025-10-26T18:07:40.610580Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.610603Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.610657Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.610717Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.611114Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156042:8516] disconnected; active server actors: 1
2025-10-26T18:07:40.611144Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156042:8516] disconnected no session
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.611540Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 12 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.611649Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.611703Z node 12 :PQ_READ_PROXY DEBUG: session cookie 7 consumer shared/user5 session shared/user5_12_7_7037793843632061402_v1 Handle describe topics response
2025-10-26T18:07:40.611869Z node 12 :PQ_READ_PROXY DEBUG: session cookie 7 consumer shared/user5 session shared/user5_12_7_7037793843632061402_v1 auth is DEAD
2025-10-26T18:07:40.611876Z node 12 :PQ_READ_PROXY INFO: session cookie 7 consumer shared/user5 session shared/user5_12_7_7037793843632061402_v1 closed with error: reason# no read rule provided for consumer 'shared/user5' in topic '/Root/PQ/rt3.dc1--topic12' in current cluster 'dc1'
2025-10-26T18:07:40.612051Z node 12 :PQ_READ_PROXY INFO: session cookie 7 consumer shared/user5 session shared/user5_12_7_7037793843632061402_v1 is DEAD
=== Got response: status: BAD_REQUEST issues { message: "no read rule provided for consumer \'shared/user5\' in topic \'/Root/PQ/rt3.dc1--topic12\' in current cluster \'dc1\'" issue_code: 500032 severity: 1 }
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user5" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user5"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.614348Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.614364Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.614372Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.614382Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.614787Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.614799Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 8
2025-10-26T18:07:40.614915Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156051:8489] connected; active server actors: 1
2025-10-26T18:07:40.615275Z node 12 :PQ_READ_PROXY DEBUG: session cookie 8 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user5" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.615427Z node 12 :PQ_READ_PROXY INFO: session cookie 8 consumer shared/user5 session shared/user5_12_8_2819591564375795006_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user5" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.615636Z node 12 :PQ_READ_PROXY DEBUG: session cookie 8 consumer shared/user5 session shared/user5_12_8_2819591564375795006_v1 auth for : user5
2025-10-26T18:07:40.615866Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.615881Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.615917Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.615963Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.616781Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 13 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.616879Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156051:8489] disconnected; active server actors: 1
2025-10-26T18:07:40.616888Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.616936Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156051:8489] disconnected no session
2025-10-26T18:07:40.617101Z node 12 :PQ_READ_PROXY DEBUG: session cookie 8 consumer shared/user5 session shared/user5_12_8_2819591564375795006_v1 Handle describe topics response
2025-10-26T18:07:40.617254Z node 12 :PQ_READ_PROXY DEBUG: session cookie 8 consumer shared/user5 session shared/user5_12_8_2819591564375795006_v1 auth is DEAD
2025-10-26T18:07:40.617391Z node 12 :PQ_READ_PROXY INFO: session cookie 8 consumer shared/user5 session shared/user5_12_8_2819591564375795006_v1 closed with error: reason# no read rule provided for consumer 'shared/user5' in topic '/Root/PQ/rt3.dc1--topic12' in current cluster 'dc1'
2025-10-26T18:07:40.617763Z node 12 :PQ_READ_PROXY INFO: session cookie 8 consumer shared/user5 session shared/user5_12_8_2819591564375795006_v1 is DEAD
=== Got response: status: BAD_REQUEST issues { message: "no read rule provided for consumer \'shared/user5\' in topic \'/Root/PQ/rt3.dc1--topic12\' in current cluster \'dc1\'" issue_code: 500032 severity: 1 }
BEFORE MODIFY PERMISSIONS
2025-10-26T18:07:40.632960Z node 12 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpModifyACL, opId: 281474976710703:0, at schemeshard:  72057594046644480
==== Writer - read
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic1" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic1"
  }
}
2025-10-26T18:07:40.637509Z node 12 :PQ_READ_PROXY DEBUG: new grpc connection
2025-10-26T18:07:40.637533Z node 12 :PQ_READ_PROXY DEBUG: new session created cookie 9
2025-10-26T18:07:40.638122Z node 12 :PQ_READ_PROXY DEBUG: session cookie 9 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.638307Z node 12 :PQ_READ_PROXY INFO: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 read init: from# ipv6:[::1]:33926, request# { init_request { topics_read_settings { topic: "topic12" } read_only_original: true consumer: "user1" read_params { max_read_messages_count: 1 } } }
2025-10-26T18:07:40.638639Z node 12 :PQ_READ_PROXY DEBUG: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 auth for : user1
2025-10-26T18:07:40.638709Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:40.638726Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:40.638783Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:40.638807Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.638817Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.638825Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.638839Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.639219Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 14 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:40.639271Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156077:8538] connected; active server actors: 1
2025-10-26T18:07:40.639323Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:40.639393Z node 12 :PQ_READ_PROXY DEBUG: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 Handle describe topics response
2025-10-26T18:07:40.639524Z node 12 :PQ_READ_PROXY DEBUG: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 Send client acl request
2025-10-26T18:07:40.639756Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic1"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      PartitionResult {
        Partition: 1
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:40.640544Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156077:8538] disconnected; active server actors: 1
2025-10-26T18:07:40.640578Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic rt3.dc1--topic1 pipe [12:7565593741045156077:8538] disconnected no session
2025-10-26T18:07:40.640774Z node 12 :PQ_READ_PROXY DEBUG: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 auth is DEAD
2025-10-26T18:07:40.640821Z node 12 :PQ_READ_PROXY INFO: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 auth ok: topics# 1, initDone# 0
2025-10-26T18:07:40.641795Z node 12 :PQ_READ_PROXY INFO: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 register session: topic# rt3.dc1--topic12
=== Got response: status: SUCCESS init_response { session_id: "shared/user1_12_9_11102617971591949816_v1" }
==== Start second loop
PQ Client: create topic: rt3.dc1--account--test-topic123 with 1 partitions
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--account--test-topic123"
  }
}
2025-10-26T18:07:40.644719Z node 12 :PQ_READ_PROXY DEBUG: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 grpc read done: success# 0, data# {  }
2025-10-26T18:07:40.644741Z node 12 :PQ_READ_PROXY INFO: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 grpc read failed
2025-10-26T18:07:40.644764Z node 12 :PQ_READ_PROXY INFO: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 grpc closed
2025-10-26T18:07:40.644786Z node 12 :PQ_READ_PROXY INFO: session cookie 9 consumer shared/user1 session shared/user1_12_9_11102617971591949816_v1 is DEAD
2025-10-26T18:07:40.644867Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045156085:4367] connected; active server actors: 1
2025-10-26T18:07:40.645323Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.645341Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.645349Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.645363Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.645426Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:40.645789Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer "user1" register session for pipe [12:7565593741045156085:4367] session shared/user1_12_9_11102617971591949816_v1
2025-10-26T18:07:40.645834Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 register readable partition 0
CallPersQueueGRPC response:
2025-10-26T18:07:40.645890Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 family created family=1 (Status=Free, Partitions=[0])
2025-10-26T18:07:40.645924Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 register reading session ReadingSession "shared/user1_12_9_11102617971591949816_v1" (Sender=[12:7565593741045156073:4367], Pipe=[12:7565593741045156085:4367], Partitions=[], ActiveFamilyCount=0)
2025-10-26T18:07:40.645949Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037895] topic rt3.dc1--topic12 consumer user1 rebalancing was scheduled
2025-10-26T18:07:40.645987Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045156085:4367] disconnected; active server actors: 1
2025-10-26T18:07:40.646012Z node 12 :PERSQUEUE_READ_BALANCER NOTICE: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593741045156085:4367] client user1 disconnected session shared/user1_12_9_11102617971591949816_v1
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--account--test-topic123, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdCreateTopic {
    Topic: "rt3.dc1--account--test-topic123"
    NumPartitions: 1
    Config {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user"
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
    }
  }
}
CallPersQueueGRPC response:
Status: 129
ProxyErrorCode: 53
SchemeStatus: 1
FlatTxId {
  TxId: 281474976710704
  SchemeShardTabletId: 72057594046644480
  PathId: 15
}
ErrorCode: OK
AddTopic: rt3.dc1--account--test-topic123
===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 = account/test-topic123, dc = dc1
2025-10-26T18:07:40.671170Z node 12 :PERSQUEUE NOTICE: Tablet 72075186224037899 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:07:40.671219Z node 12 :PERSQUEUE INFO: Tablet 72075186224037899 doesn't have tx writes info
2025-10-26T18:07:40.717495Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037900] topic  pipe [12:7565593741045156103:8571] connected; active server actors: 1
2025-10-26T18:07:40.717852Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037900] topic rt3.dc1--account--test-topic123 updating configuration. Deleted partitions []. Added partitions [0]
2025-10-26T18:07:40.719407Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037900
2025-10-26T18:07:40.719527Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: BALANCER INIT DONE for rt3.dc1--account--test-topic123: (0, 72075186224037899) 
2025-10-26T18:07:40.720438Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037900 topic rt3.dc1--account--test-topic123 TEvClientConnected TabletId 72057594046644480, NodeId 12, Generation 2
2025-10-26T18:07:40.720624Z node 12 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037900 topic rt3.dc1--account--test-topic123 TEvClientConnected TabletId 72075186224037899, NodeId 12, Generation 1
2025-10-26T18:07:40.729316Z node 12 :PERSQUEUE INFO: bootstrapping 0 [12:7565593741045156191:4367]
2025-10-26T18:07:40.733129Z node 12 :PERSQUEUE INFO: init complete for topic 'rt3.dc1--account--test-topic123' partition 0 generation 1 [12:7565593741045156191:4367]
2025-10-26T18:07:40.740019Z node 12 :PERSQUEUE NOTICE: Tablet 72075186224037899 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:07:40.950633Z node 12 :KQP_EXECUTER ERROR: TxId: 281474976710705. Ctx: { TraceId: 01k8gv8r4gfpm0c426g3810x3s, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=12&id=YmFmNWFmNC1mMDI5OTNkMi1jMjczOGMxNC00OThhNjk4Yg==, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
===Query complete
TClient::Ls request: /Root/PQ/rt3.dc1--account--test-topic123
TClient::Ls response: Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--account--test-topic123"
    PathId: 15
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710704
    CreateStep: 1761502060773
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    BalancerTabletID: 72075186224037900
  }
  PersQueueGroup {
    Name: "rt3.dc1--account--test-topic123"
    PathId: 15
    TotalGroupCount: 1
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstS...
(TRUNCATED)
GetTopicVersionFromPath:  record Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--account--test-topic123"
    PathId: 15
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710704
    CreateStep: 1761502060773
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    BalancerTabletID: 72075186224037900
  }
  PersQueueGroup {
    Name: "rt3.dc1--account--test-topic123"
    PathId: 15
    TotalGroupCount: 1
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user"
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
      YdbDatabasePath: "/Root"
    }
    Partitions {
      PartitionId: 0
      TabletId: 72075186224037899
      Status: Active
    }
    AlterVersion: 1
    BalancerTabletID: 72075186224037900
    NextPartitionId: 1
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 1
      PlanResolution: 7
      Coordinators: 72057594046316545
      TimeCastBucketsPerMediator: 2
      Mediators: 72057594046382081
    }
    DomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    PathsInside: 14
    PathsLimit: 10000
    ShardsInside: 13
    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: 4
    PQPartitionsLimit: 1000000
  }
}
Path: "/Root/PQ/rt3.dc1--account--test-topic123"
 name rt3.dc1--account--test-topic123 version1
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--account--test-topic123"
  }
}
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--account--test-topic123, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
2025-10-26T18:07:40.996363Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:40.996389Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:40.996397Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:40.996413Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 2 topics
2025-10-26T18:07:40.996479Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:41.057792Z node 12 :FLAT_TX_SCHEMESHARD WARN: Cannot get console configs
2025-10-26T18:07:41.057833Z node 12 :IMPORT WARN: Table profiles were not loaded
2025-10-26T18:07:41.155180Z node 12 :PQ_METACACHE DEBUG: Check version rescan
2025-10-26T18:07:41.174132Z node 12 :PQ_METACACHE DEBUG: Got config version: 3
2025-10-26T18:07:41.184250Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:41.196995Z node 12 :PQ_METACACHE DEBUG: HandleGetTopicsResult
2025-10-26T18:07:41.197445Z node 12 :PQ_METACACHE DEBUG: Updated topics list with : 3 topics
2025-10-26T18:07:41.197453Z node 12 :PQ_METACACHE DEBUG: Metacache: reset
2025-10-26T18:07:41.301244Z node 12 :PQ_METACACHE DEBUG: HandleClustersUpdate
2025-10-26T18:07:41.301269Z node 12 :PQ_METACACHE DEBUG: HandleClustersUpdate LocalCluster !LocalCluster.empty()
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--account--test-topic123"
  }
}
2025-10-26T18:07:41.503217Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:41.503243Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:41.503251Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics SendSchemeCacheRequest
2025-10-26T18:07:41.503270Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:41.503359Z node 12 :PQ_METACACHE DEBUG: send request for  all 3 topics, got 1 requests infly, db = ""
2025-10-26T18:07:41.504989Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 15 ResultSet [{ Path: Root/PQ/rt3.dc1--account--test-topic123 TableId: [72057594046644480:15:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: false Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } },{ Path: Root/PQ/rt3.dc1--topic1 TableId: [72057594046644480:9:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: false Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } },{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: false Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:41.505005Z node 12 :PQ_METACACHE DEBUG: Got describe all topics SC response
2025-10-26T18:07:41.505293Z node 12 :PQ_METACACHE DEBUG: Updated topics cache with 3
2025-10-26T18:07:41.505306Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 3 topics
2025-10-26T18:07:41.505603Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetTopicMetadataResult {
    TopicInfo {
      Topic: "rt3.dc1--account--test-topic123"
      NumPartitions: 1
      Config {
        PartitionConfig {
          LifetimeSeconds: 86400
          LowWatermark: 8388608
          SourceIdLifetimeSeconds: 86400
          WriteSpeedInBytesPerSecond: 20000000
          BurstSize: 20000000
          SourceIdMaxCounts: 6000000
        }
        Version: 1
        LocalDC: true
        ReadRules: "user"
        ReadFromTimestampsMs: 0
        ConsumerFormatVersions: 0
        ConsumerCodecs {
        }
        Codecs {
          Ids: 0
          Ids: 1
          Ids: 2
          Codecs: "raw"
          Codecs: "gzip"
          Codecs: "lzop"
        }
        ReadRuleVersions: 0
        TopicPath: "/Root/PQ/rt3.dc1--account--test-topic123"
        YdbDatabasePath: "/Root"
        Consumers {
          Name: "user"
          ReadFromTimestampsMs: 0
          FormatVersion: 0
          Codec {
         ...
(TRUNCATED)
=== Topic created, have version: 1
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic12" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic12"
  }
}
2025-10-26T18:07:41.512258Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:41.512285Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:41.512293Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:41.512307Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 3 topics
2025-10-26T18:07:41.512903Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123650:8590] connected; active server actors: 1
2025-10-26T18:07:41.513304Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:41.514239Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123650:8590] disconnected; active server actors: 1
2025-10-26T18:07:41.514278Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123650:8590] disconnected no session
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic12"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 1
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 1
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:41.525903Z node 12 :PQ_READ_PROXY DEBUG: new read info request
2025-10-26T18:07:41.526272Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 auth for : user1
2025-10-26T18:07:41.526493Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:41.526513Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:41.526576Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:41.527114Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 16 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:41.527226Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:41.527411Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 Handle describe topics response
2025-10-26T18:07:41.527566Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 auth is DEAD
Response: { operation { ready: true status: UNAUTHORIZED issues { message: "No ReadTopic permissions for \'/Root/PQ/rt3.dc1--topic12\' for subject \'user_without_rights@builtin\'" issue_code: 500018 severity: 1 } } }
{  }
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic12" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic12"
  }
}
2025-10-26T18:07:41.537819Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:41.537844Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:41.537852Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:41.537866Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 3 topics
2025-10-26T18:07:41.541249Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123661:8575] connected; active server actors: 1
2025-10-26T18:07:41.541754Z node 12 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic12"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:41.543384Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123661:8575] disconnected; active server actors: 1
2025-10-26T18:07:41.543423Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123661:8575] disconnected no session
2025-10-26T18:07:41.544778Z node 12 :TICKET_PARSER ERROR: Ticket **** (E7252F7C): Could not find correct token validator
2025-10-26T18:07:41.544926Z node 12 :PQ_READ_PROXY DEBUG: new read info request
Response: { operation { ready: true status: UNAUTHORIZED issues { message: "Unauthenticated access is forbidden, please provide credentials" issue_code: 500018 severity: 1 } } }
{  }
Request: { MetaRequest { CmdGetReadSessionsInfo { ClientId: "user1" Topic: "rt3.dc1--topic12" } } }
CallPersQueueGRPC request to localhost:26580
MetaRequest {
  CmdGetReadSessionsInfo {
    ClientId: "user1"
    Topic: "rt3.dc1--topic12"
  }
}
2025-10-26T18:07:41.547546Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:41.547567Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:41.547576Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:41.547590Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 3 topics
2025-10-26T18:07:41.548151Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123670:8535] connected; active server actors: 1
2025-10-26T18:07:41.548535Z node 12 :PERSQUEUE INFO: proxy answer <none>
2025-10-26T18:07:41.549419Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123670:8535] disconnected; active server actors: 1
2025-10-26T18:07:41.549450Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123670:8535] disconnected no session
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetReadSessionsInfoResult {
    TopicResult {
      Topic: "rt3.dc1--topic12"
      PartitionResult {
        Partition: 0
        ClientOffset: 0
        StartOffset: 0
        EndOffset: 0
        TimeLag: 0
        TabletNode: "::1"
        ClientReadOffset: 0
        ReadTimeLag: 0
        TabletNodeId: 12
        ErrorCode: OK
      }
      ErrorCode: OK
    }
  }
}
2025-10-26T18:07:41.551183Z node 12 :PQ_READ_PROXY DEBUG: new read info request
2025-10-26T18:07:41.551411Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 auth for : user1
2025-10-26T18:07:41.551614Z node 12 :PQ_METACACHE DEBUG: Handle describe topics
2025-10-26T18:07:41.551635Z node 12 :PQ_METACACHE DEBUG: SendSchemeCacheRequest
2025-10-26T18:07:41.551709Z node 12 :PQ_METACACHE DEBUG: send request for 1 topics, got 1 requests infly, db = ""
2025-10-26T18:07:41.552298Z node 12 :PQ_METACACHE DEBUG: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 17 ResultSet [{ Path: Root/PQ/rt3.dc1--topic12 TableId: [72057594046644480:10:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) } }] }
2025-10-26T18:07:41.552410Z node 12 :PQ_METACACHE DEBUG: Got describe topics SC response
2025-10-26T18:07:41.552652Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 Handle describe topics response
2025-10-26T18:07:41.552817Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 Send client acl request
2025-10-26T18:07:41.553386Z node 12 :PQ_READ_PROXY DEBUG: session cookie 0 consumer shared/user1 session read_info:ipv6:[::1]:33926 auth is DEAD
2025-10-26T18:07:41.553485Z node 12 :PQ_READ_PROXY DEBUG: GetReadInfo auth ok fo read info, got 1 topics
2025-10-26T18:07:41.553759Z node 12 :PQ_METACACHE DEBUG: HandleDescribeAllTopics
2025-10-26T18:07:41.553774Z node 12 :PQ_METACACHE DEBUG: ProcessDescribeAllTopics
2025-10-26T18:07:41.553783Z node 12 :PQ_METACACHE DEBUG: Respond from cache
2025-10-26T18:07:41.553802Z node 12 :PQ_METACACHE DEBUG: Send describe all topics response with 3 topics
2025-10-26T18:07:41.554682Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123682:4361] connected; active server actors: 1
Response: { operation { ready: true status: SUCCESS result { type_url: "type.googleapis.com/Ydb.PersQueue.V1.ReadInfoResult" value: "\n\037\n\t\n\007topic12\022\003dc1\030\200\265\030*\t\020\200\265\030j\003::1" } } }
{ topics { topic { path: "topic12" } cluster: "dc1" status: SUCCESS partitions { status: SUCCESS tablet_node: "::1" } } }
2025-10-26T18:07:41.560500Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123682:4361] disconnected; active server actors: 1
2025-10-26T18:07:41.560547Z node 12 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037895] topic rt3.dc1--topic12 pipe [12:7565593745340123682:4361] disconnected no session
