2025-12-12T11:57:30.537557Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:30.537763Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:30.538008Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:30.538057Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:30.538172Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:30.545366Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.545389Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540650545 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.545418Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0"
2025-12-12T11:57:30.545427Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:30.545520Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:30.545589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:30.547093Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:30.547109Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:30.547115Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:30.547409Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:30.547535Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:30.547575Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:30.547696Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:30.555877Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.555932Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ed1a568c-f39a8b5a-5106a954-d4ace7f6_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0"
2025-12-12T11:57:30.555939Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:30.556027Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=1, AckCount=0
2025-12-12T11:57:30.556046Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:30.556066Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.556072Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:30.556219Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=2, AckCount=0
2025-12-12T11:57:30.556225Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:30.556229Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.556231Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:30.556236Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=3, AckCount=0
2025-12-12T11:57:30.556240Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:30.556243Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.556244Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:30.556247Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=4, AckCount=0
2025-12-12T11:57:30.556250Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:30.556256Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.556260Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:30.556553Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:30.556792Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:30.557082Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:30.557120Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:30.557230Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:30.560529Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.560588Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_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-12T11:57:30.560604Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=4, AckCount=1
2025-12-12T11:57:30.560609Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:30.561319Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.561375Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_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-12T11:57:30.561386Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=4, AckCount=2
2025-12-12T11:57:30.561390Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:30.561434Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.561457Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:30.561464Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=4, AckCount=3
2025-12-12T11:57:30.561467Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:30.561489Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.561500Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_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-12T11:57:30.561504Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=4, AckCount=4
2025-12-12T11:57:30.561506Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:30.563316Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.563338Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540650563 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.563362Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0"
2025-12-12T11:57:30.563368Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:30.563437Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:30.563512Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:30.565039Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:30.565058Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:30.565064Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:30.565418Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:30.565560Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:30.565602Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:30.565708Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:30.571946Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.572028Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d0464185-778ff8a-96a5a7de-b70ad5b8_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0"
2025-12-12T11:57:30.572035Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:30.572119Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=1, AckCount=0
2025-12-12T11:57:30.572139Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:30.572164Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.572188Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:30.572329Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=2, AckCount=0
2025-12-12T11:57:30.572335Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:30.572341Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.572344Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:30.572351Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=3, AckCount=0
2025-12-12T11:57:30.572369Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:30.572373Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.572376Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:30.572380Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=4, AckCount=0
2025-12-12T11:57:30.572384Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:30.572391Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.572394Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:30.572581Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=5, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=5, AckCount=0
2025-12-12T11:57:30.572588Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 5 to 5
2025-12-12T11:57:30.572594Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.572598Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-12-12T11:57:30.572649Z :INFO: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Starting read session
2025-12-12T11:57:30.572654Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Starting single session
2025-12-12T11:57:30.572911Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.572916Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.572921Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:30.573147Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Successfully connected. Initializing session
2025-12-12T11:57:30.574037Z :INFO: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1
2025-12-12T11:57:30.574056Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.574140Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.575687Z :INFO: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:30.575759Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.575785Z :DEBUG: [local] 0x0000514CBF74A110 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:30.575806Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:30.575820Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_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-12T11:57:30.575831Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=5, AckCount=1
2025-12-12T11:57:30.575836Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:30.575994Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:30.576000Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.576025Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:30.576052Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:30.576088Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer" }
2025-12-12T11:57:30.576552Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.576584Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_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-12T11:57:30.576596Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=5, AckCount=2
2025-12-12T11:57:30.576600Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:30.576666Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.576686Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:30.576691Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=5, AckCount=3
2025-12-12T11:57:30.576693Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:30.576717Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.576728Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_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-12T11:57:30.576733Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=5, AckCount=4
2025-12-12T11:57:30.576735Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:30.576747Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:30.576756Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:30.576759Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.576768Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.576775Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.576813Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.576824Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 5 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-12T11:57:30.576828Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=5, txId={ydb://session/3?node_id=1&id=YThkY2RlOTktODYwNmY1NGMtNzliM2JiNmUtNjBjOGMxNTY=, 01kc96rqh96tz5189j8752h1rx}, WriteCount=5, AckCount=5
2025-12-12T11:57:30.576831Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 5
2025-12-12T11:57:30.577302Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.577311Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:31.573344Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_A:0:1:0:0
2025-12-12T11:57:31.573373Z :INFO: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:32.576203Z :INFO: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Starting read session
2025-12-12T11:57:32.576225Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Starting single session
2025-12-12T11:57:32.576521Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:32.576527Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:32.576533Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:32.576879Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Successfully connected. Initializing session
2025-12-12T11:57:32.578171Z :INFO: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1
2025-12-12T11:57:32.578192Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:32.578270Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:32.579716Z :INFO: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:32.579828Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:32.579858Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:32.580072Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:32.580079Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:32.580082Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:32.580111Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:32.580167Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_B" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer" }
2025-12-12T11:57:32.580841Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:32.580852Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:32.580865Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:32.580881Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:32.580886Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:32.581183Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:32.581193Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:33.577279Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_B:0:1:0:0
2025-12-12T11:57:33.577307Z :INFO: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:34.587358Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 4
2025-12-12T11:57:34.587376Z :DEBUG: [local] 0x0000514CBF60C620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:34.587452Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Got ReadResponse, serverBytesSize = 741, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428059
2025-12-12T11:57:34.587479Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428059
2025-12-12T11:57:34.587498Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 3
2025-12-12T11:57:34.587519Z :DEBUG: [local] 0x0000514CBF606320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:34.587529Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-4)
2025-12-12T11:57:34.587568Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Returning serverBytesSize = 741 to budget
2025-12-12T11:57:34.587576Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] In ContinueReadingDataImpl, ReadSizeBudget = 741, ReadSizeServerDelta = 52428059
2025-12-12T11:57:34.587585Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:34.587653Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Got ReadResponse, serverBytesSize = 599, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428201
2025-12-12T11:57:34.587681Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428201
2025-12-12T11:57:34.587737Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-3)
2025-12-12T11:57:34.587762Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Returning serverBytesSize = 599 to budget
2025-12-12T11:57:34.587768Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] In ContinueReadingDataImpl, ReadSizeBudget = 599, ReadSizeServerDelta = 52428201
2025-12-12T11:57:34.587776Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:34.587826Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:34.587840Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:34.587846Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:57:34.587851Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-12T11:57:34.587864Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] The application data is transferred to the client. Number of messages 4, size 40 bytes
2025-12-12T11:57:34.587873Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T11:57:34.587900Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Commit offsets [0, 4). Partition stream id: 1
2025-12-12T11:57:34.588979Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 4 } }
2025-12-12T11:57:36.587427Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:36.587453Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:36.587460Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:57:36.587465Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-12T11:57:36.587472Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-12-12T11:57:36.587488Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] The application data is transferred to the client. Number of messages 5, size 50 bytes
2025-12-12T11:57:36.587505Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Returning serverBytesSize = 0 to budget
0 5
2025-12-12T11:57:36.587539Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Commit offsets [0, 5). Partition stream id: 1
2025-12-12T11:57:36.589760Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 5 } }
2025-12-12T11:57:38.587526Z :INFO: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:38.587561Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_B:0:1:4:5
2025-12-12T11:57:38.587573Z :INFO: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6011 BytesRead: 50 MessagesRead: 5 BytesReadCompressed: 50 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:38.587598Z :NOTICE: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:38.587610Z :DEBUG: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] [] Abort session to cluster
2025-12-12T11:57:38.587883Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 Close
2025-12-12T11:57:38.587947Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_4683764066042657082_v1 Close
2025-12-12T11:57:38.587967Z :NOTICE: [local] [local] [a86586df-999aa1c4-44e2fc98-9b93af58] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:38.588229Z :INFO: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:38.588255Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_1/topic_A:0:1:3:4
2025-12-12T11:57:38.588264Z :INFO: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8015 BytesRead: 40 MessagesRead: 4 BytesReadCompressed: 40 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:38.588294Z :NOTICE: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:38.588302Z :DEBUG: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] [] Abort session to cluster
2025-12-12T11:57:38.588407Z :DEBUG: [local] 0x0000514CBF74A110 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 Close
2025-12-12T11:57:38.588440Z :DEBUG: [local] 0x0000514CBF74A110 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_12913453542089763055_v1 Close
2025-12-12T11:57:38.588450Z :NOTICE: [local] [local] [d94e528f-9875f8fd-b250b2f7-6b014939] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:38.588672Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:38.588683Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:38.588691Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:38.588858Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:38.588864Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|73843164-6efc0ab-7106e8d4-17cb63b9_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:38.589081Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:38.589087Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:38.589092Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:38.589126Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:38.589130Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9779c61c-15b73535-8215d94d-a33311f_0]  PartitionId [0]  Generation [1] Write session: destroy
