2025-12-12T12:00:41.454942Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T12:00:41.455151Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:41.455357Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T12:00:41.455400Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T12:00:41.455493Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:41.462451Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.462473Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540841462 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:41.462497Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0"
2025-12-12T12:00:41.462502Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:41.462560Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:41.462608Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:41.463847Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:41.463861Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:41.463866Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:41.464122Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:41.464209Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:41.464233Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T12:00:41.464311Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:41.470875Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.470912Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|50aed299-5bc4f21-476c6e7c-2f2fe81f_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0"
2025-12-12T12:00:41.470920Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:41.470979Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=1, AckCount=0
2025-12-12T12:00:41.470993Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:41.471019Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:41.471024Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:41.471138Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=2, AckCount=0
2025-12-12T12:00:41.471142Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:41.471147Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:41.471150Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:41.471222Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T12:00:41.471454Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:41.471634Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T12:00:41.471668Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T12:00:41.471729Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:41.474519Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.474561Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:41.474573Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=2, AckCount=1
2025-12-12T12:00:41.474578Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:41.475584Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.475634Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:41.475642Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=2, AckCount=2
2025-12-12T12:00:41.475646Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:41.476549Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.476567Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540841476 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:41.476584Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0"
2025-12-12T12:00:41.476589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:41.476650Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:41.476689Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:41.477719Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:41.477732Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:41.477737Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:41.477973Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:41.478037Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:41.478062Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T12:00:41.478146Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:41.483847Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.483886Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|68213816-4927a5c1-e55d3ab2-95ef83ac_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0"
2025-12-12T12:00:41.483892Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:41.483949Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:41.483993Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:41.484001Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:41.484115Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:41.484120Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:41.484122Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:41.484136Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=3, AckCount=2
2025-12-12T12:00:41.484140Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T12:00:41.484146Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:41.484147Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T12:00:41.484230Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=4, AckCount=2
2025-12-12T12:00:41.484236Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T12:00:41.484243Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:41.484246Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T12:00:41.484289Z :INFO: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Starting read session
2025-12-12T12:00:41.484292Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Starting single session
2025-12-12T12:00:41.484483Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:41.484495Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:41.484499Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:41.484675Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Successfully connected. Initializing session
2025-12-12T12:00:41.485609Z :INFO: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1
2025-12-12T12:00:41.485626Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:41.485696Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:41.485772Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.485816Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:41.485822Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T12:00:41.485826Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:41.485853Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.485887Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:41.485899Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=4, AckCount=3
2025-12-12T12:00:41.485904Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T12:00:41.486773Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.486805Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { offset: 1 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:41.486809Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T12:00:41.486813Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:41.486877Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:41.486905Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:41.486912Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=M2Q2OGYyNGItMjY4OTcyNzktMTcxZmI3OWYtMjFiZDk2YTE=, 01kc96yhze4v64kh72nwaavv6x}, WriteCount=4, AckCount=4
2025-12-12T12:00:41.486919Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T12:00:41.487822Z :INFO: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:41.487918Z :DEBUG: [local] 0x00003069FF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:41.487937Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:41.488114Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:41.488119Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:41.488126Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:41.488156Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:41.488210Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer" }
2025-12-12T12:00:41.488790Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:41.488799Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:41.488802Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:41.488810Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:41.488814Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:41.489123Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:41.489132Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:41.489263Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T12:00:41.489271Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:41.489388Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Got ReadResponse, serverBytesSize = 310, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T12:00:41.489415Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T12:00:41.489467Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:00:41.489500Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Returning serverBytesSize = 310 to budget
2025-12-12T12:00:41.489508Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] In ContinueReadingDataImpl, ReadSizeBudget = 310, ReadSizeServerDelta = 52428490
2025-12-12T12:00:41.489664Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:41.489731Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:41.489744Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:00:41.489754Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T12:00:41.489761Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T12:00:41.489781Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:00:41.491003Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T12:00:42.485316Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A:0:1:1:2
2025-12-12T12:00:42.485340Z :INFO: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:43.487782Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 2 lastOffset = 5
2025-12-12T12:00:43.487800Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T12:00:43.487938Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Got ReadResponse, serverBytesSize = 598, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428202
2025-12-12T12:00:43.487959Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428202
2025-12-12T12:00:43.488002Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-5)
2025-12-12T12:00:43.488027Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Returning serverBytesSize = 598 to budget
2025-12-12T12:00:43.488034Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] In ContinueReadingDataImpl, ReadSizeBudget = 598, ReadSizeServerDelta = 52428202
2025-12-12T12:00:43.488136Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:43.488207Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:00:43.488227Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T12:00:43.488232Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (4-4)
2025-12-12T12:00:43.488236Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (5-5)
2025-12-12T12:00:43.488245Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] The application data is transferred to the client. Number of messages 4, size 40 bytes
2025-12-12T12:00:43.488253Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T12:00:43.488279Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Commit offsets [2, 6). Partition stream id: 1
2025-12-12T12:00:43.489688Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 6 } }
2025-12-12T12:00:45.487569Z :INFO: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:45.487591Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_7/topic_A:0:1:5:6
2025-12-12T12:00:45.487601Z :INFO: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4003 BytesRead: 60 MessagesRead: 6 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:45.487616Z :NOTICE: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:45.487623Z :DEBUG: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] [] Abort session to cluster
2025-12-12T12:00:45.487781Z :DEBUG: [local] 0x00003069FF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 Close
2025-12-12T12:00:45.487805Z :DEBUG: [local] 0x00003069FF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_7-test-consumer_1_11_13184646216541674679_v1 Close
2025-12-12T12:00:45.487815Z :NOTICE: [local] [local] [ff8ffd41-252484b3-cf2db1d7-e86e6dd7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:45.487945Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:45.487948Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:45.487952Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:45.487970Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:45.487972Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|164e899-8be70198-679f3ac5-c548afe4_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:00:45.488125Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:45.488129Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:45.488131Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:45.488232Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:45.488239Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|aae92188-607506be-febf5e57-1ff7520f_0]  PartitionId [0]  Generation [1] Write session: destroy
