2025-12-12T11:55:06.604871Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:55:06.605125Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:06.606561Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T11:55:06.608370Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:55:06.608570Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.351604Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.351629Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540507351 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:07.351660Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0"
2025-12-12T11:55:07.351664Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.351699Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:07.351795Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:07.353328Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:07.353349Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:07.353356Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:07.353820Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:07.353920Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:07.353964Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:55:07.354083Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.360827Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.360872Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|bf85e62d-8d3d70d5-ddacfdd7-dce14d90_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0"
2025-12-12T11:55:07.360877Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.361567Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=1, AckCount=0
2025-12-12T11:55:07.361589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:07.361630Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.361637Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:07.361800Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=2, AckCount=0
2025-12-12T11:55:07.361806Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:07.361812Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.361815Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:07.361888Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=3, AckCount=0
2025-12-12T11:55:07.361894Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:55:07.361899Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.361901Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:55:07.361908Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=4, AckCount=0
2025-12-12T11:55:07.361912Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:55:07.361919Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.361921Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:55:07.362002Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:55:07.362240Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:07.362532Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T11:55:07.366212Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.423477Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:55:07.423640Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_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:55:07.423658Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=4, AckCount=1
2025-12-12T11:55:07.423663Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:07.423733Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.423886Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.423946Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_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:55:07.423956Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=4, AckCount=2
2025-12-12T11:55:07.423959Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:07.424004Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.424016Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_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:55:07.424021Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=4, AckCount=3
2025-12-12T11:55:07.424024Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:55:07.424057Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.424070Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_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:55:07.424076Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=4, AckCount=4
2025-12-12T11:55:07.424079Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:55:07.430533Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.430556Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540507430 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:07.430584Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0"
2025-12-12T11:55:07.430589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.430668Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:07.430721Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:07.431900Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:07.431919Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:07.431925Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:07.432234Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:07.432345Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:07.432380Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:55:07.432471Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.440907Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.440950Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e512ca62-448e34ec-315a83dd-3b94c7ef_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0"
2025-12-12T11:55:07.440957Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.441020Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:07.441064Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.441073Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:07.441276Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:55:07.441539Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:07.441806Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T11:55:07.441848Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:55:07.441960Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.442811Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.442853Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_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-12T11:55:07.442859Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:55:07.442864Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:07.449237Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.449257Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540507449 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:07.449304Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0"
2025-12-12T11:55:07.449325Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.449396Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:07.449443Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:07.450935Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:07.450952Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:07.527336Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:07.528680Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:07.528881Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:07.528928Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:55:07.529052Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.535959Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.536002Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|279a2c08-e38a14bf-a68c2484-7e150d34_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0"
2025-12-12T11:55:07.536008Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.536073Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:07.536104Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.536110Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:07.536342Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:55:07.536660Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:07.536992Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T11:55:07.537028Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:55:07.537141Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.538061Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.538101Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:07.538108Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:55:07.538112Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:07.547435Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.547460Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540507547 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:07.547495Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0"
2025-12-12T11:55:07.547540Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.547629Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:07.547693Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:07.549147Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:07.549166Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:07.549171Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:07.549511Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:07.549639Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:07.549669Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:55:07.549790Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:07.556352Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.556403Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|f74b2828-927ff2ef-7dbdb69d-21e14fc8_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0"
2025-12-12T11:55:07.556409Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:07.556486Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=1, AckCount=0
2025-12-12T11:55:07.556505Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:07.556541Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.629128Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:07.629388Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=2, AckCount=0
2025-12-12T11:55:07.629401Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:07.629430Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.629435Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:07.629444Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=3, AckCount=0
2025-12-12T11:55:07.629450Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:55:07.629455Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:07.629457Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:55:07.629517Z :INFO: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Starting read session
2025-12-12T11:55:07.629525Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Starting single session
2025-12-12T11:55:07.629905Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:07.629915Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:07.629921Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:07.630427Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Successfully connected. Initializing session
2025-12-12T11:55:07.631625Z :INFO: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1
2025-12-12T11:55:07.631648Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:07.631715Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:07.633172Z :INFO: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:07.633402Z :DEBUG: [local] 0x00001393BF743910 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:07.633427Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:07.633710Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:07.633718Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:07.633721Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:07.633905Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:07.634099Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer" }
2025-12-12T11:55:07.634308Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.634339Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:07.634350Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=3, AckCount=1
2025-12-12T11:55:07.634355Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:07.634796Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.634835Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:07.634847Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=3, AckCount=2
2025-12-12T11:55:07.634851Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:07.635047Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:07.635071Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:07.635078Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=MWZmODExNWItNGNmZThhNjItMTBmNTJhODQtM2NjYjZkOTg=, 01kc96maz42rrj0nx551ax42ce}, WriteCount=3, AckCount=3
2025-12-12T11:55:07.635081Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:55:07.635308Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:07.635322Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:07.635326Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:07.635338Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:07.635345Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:07.635776Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:07.635786Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:07.635902Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:55:07.731271Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:07.731560Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Got ReadResponse, serverBytesSize = 166, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:55:07.731603Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:55:07.731653Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:55:07.731680Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Returning serverBytesSize = 166 to budget
2025-12-12T11:55:07.731687Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] In ContinueReadingDataImpl, ReadSizeBudget = 166, ReadSizeServerDelta = 52428634
2025-12-12T11:55:07.731834Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:07.731909Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:07.731928Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:55:07.731935Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:55:07.731967Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:55:07.733950Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:55:08.630358Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A:0:1:0:1
2025-12-12T11:55:08.630390Z :INFO: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:09.629623Z :INFO: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Starting read session
2025-12-12T11:55:09.629642Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Starting single session
2025-12-12T11:55:09.629901Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:09.629906Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:09.629912Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:09.630289Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Successfully connected. Initializing session
2025-12-12T11:55:09.640625Z :INFO: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1
2025-12-12T11:55:09.640673Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:09.640759Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:09.648517Z :INFO: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:09.648605Z :DEBUG: [local] 0x00001393BF745310 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:09.648633Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:09.648802Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:09.648806Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:09.648808Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:09.649414Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:09.649465Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer" }
2025-12-12T11:55:09.652358Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:09.652376Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:09.652380Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:09.652393Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:09.652400Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:09.653150Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:09.653162Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:09.653227Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:55:09.653233Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:09.653348Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Got ReadResponse, serverBytesSize = 166, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:55:09.653380Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:55:09.653439Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:55:09.653465Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Returning serverBytesSize = 166 to budget
2025-12-12T11:55:09.653473Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] In ContinueReadingDataImpl, ReadSizeBudget = 166, ReadSizeServerDelta = 52428634
2025-12-12T11:55:09.653610Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:09.653673Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:09.653696Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:55:09.653704Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:55:09.653724Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:55:09.656051Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:55:10.630332Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B:0:1:0:1
2025-12-12T11:55:10.630363Z :INFO: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:11.639503Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 3
2025-12-12T11:55:11.639526Z :DEBUG: [local] 0x00001393BFBC6320 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:55:11.639687Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Got ReadResponse, serverBytesSize = 463, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428337
2025-12-12T11:55:11.639698Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 4
2025-12-12T11:55:11.639711Z :DEBUG: [local] 0x00001393BFBC2C20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:55:11.639727Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428337
2025-12-12T11:55:11.639774Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-3)
2025-12-12T11:55:11.639800Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Returning serverBytesSize = 463 to budget
2025-12-12T11:55:11.639808Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] In ContinueReadingDataImpl, ReadSizeBudget = 463, ReadSizeServerDelta = 52428337
2025-12-12T11:55:11.639836Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Got ReadResponse, serverBytesSize = 607, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428193
2025-12-12T11:55:11.639867Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428193
2025-12-12T11:55:11.639908Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:11.639917Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-4)
2025-12-12T11:55:11.639941Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Returning serverBytesSize = 607 to budget
2025-12-12T11:55:11.639948Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] In ContinueReadingDataImpl, ReadSizeBudget = 607, ReadSizeServerDelta = 52428193
2025-12-12T11:55:11.640049Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:11.640116Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:55:11.640130Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-12-12T11:55:11.640136Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (3-3)
2025-12-12T11:55:11.640140Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (4-4)
2025-12-12T11:55:11.640153Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] The application data is transferred to the client. Number of messages 4, size 40 bytes
2025-12-12T11:55:11.640160Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T11:55:11.640198Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Commit offsets [1, 5). Partition stream id: 1
2025-12-12T11:55:11.642872Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 5 } }
2025-12-12T11:55:13.639542Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:55:13.639568Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-12-12T11:55:13.639575Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (3-3)
2025-12-12T11:55:13.639591Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:55:13.639604Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:55:13.639634Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Commit offsets [1, 4). Partition stream id: 1
2025-12-12T11:55:13.642044Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 4 } }
2025-12-12T11:55:15.639611Z :INFO: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:15.639637Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_B:0:1:3:4
2025-12-12T11:55:15.639645Z :INFO: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6010 BytesRead: 40 MessagesRead: 4 BytesReadCompressed: 40 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:15.639667Z :NOTICE: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:15.639675Z :DEBUG: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] [] Abort session to cluster
2025-12-12T11:55:15.639868Z :DEBUG: [local] 0x00001393BF745310 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 Close
2025-12-12T11:55:15.639908Z :DEBUG: [local] 0x00001393BF745310 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_4521611807592387995_v1 Close
2025-12-12T11:55:15.639921Z :NOTICE: [local] [local] [9e686eb3-2fd1246a-ca4a004d-194f6ad8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:15.644339Z :INFO: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:15.644363Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_2/topic_A:0:1:4:5
2025-12-12T11:55:15.644372Z :INFO: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8014 BytesRead: 50 MessagesRead: 5 BytesReadCompressed: 50 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:15.644392Z :NOTICE: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:15.644403Z :DEBUG: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] [] Abort session to cluster
2025-12-12T11:55:15.644605Z :DEBUG: [local] 0x00001393BF743910 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 Close
2025-12-12T11:55:15.644630Z :DEBUG: [local] 0x00001393BF743910 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_11734472264094535078_v1 Close
2025-12-12T11:55:15.644642Z :NOTICE: [local] [local] [8889d8a4-c3e98ab4-20a017f0-51abf74a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:15.645261Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:15.645272Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:15.645279Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:15.645323Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:15.645327Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|e57113ec-472f6240-d32e9465-94d222a2_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:15.652422Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:15.652439Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:15.652448Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:15.652606Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:15.652611Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|148471dc-19a0cd38-be29315b-6b268a9_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:15.664358Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:15.664373Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:15.664383Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:15.664584Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:15.664589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|d364a50c-cd190569-c8c84a3f-cbd1137b_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:15.672432Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:15.672442Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:15.672450Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:15.672616Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:15.672621Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|1c221094-11a5fa4f-6bdf9684-a7fb25ef_0]  PartitionId [0]  Generation [1] Write session: destroy
