2025-12-12T11:55:26.660099Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:55:26.660349Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:26.660717Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:55:26.660773Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_17/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:55:26.660904Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:26.667032Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.667056Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540526667 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:26.667081Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0"
2025-12-12T11:55:26.667087Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:26.667163Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:26.667212Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:26.668402Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_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:26.668417Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:26.668423Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:26.668686Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:26.668797Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:26.668822Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_17/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:55:26.668913Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:26.675496Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.675550Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|5b9b8843-cd16ad45-c98ae2d0-67cf5da2_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0"
2025-12-12T11:55:26.675559Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:26.702367Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:26.726179Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.726200Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:26.750522Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Estimated memory usage 22000000[B] reached maximum (20971520[B])
2025-12-12T11:55:26.852847Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.852946Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 34000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:26.852956Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:55:26.852961Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:26.852967Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 0[B]
2025-12-12T11:55:26.860168Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:26.860229Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.860237Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:26.860473Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:55:26.860480Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.860483Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:55:26.860492Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:55:26.860500Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.860503Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:55:26.874628Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 5 to 5
2025-12-12T11:55:26.886779Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.886803Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-12-12T11:55:26.901695Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=6, txId={ydb://session/3?node_id=1&id=ZWUxYjg5NmUtNWUwYThjN2UtYzhiZTI1ZjItNjE3NDY5NTY=, 01kc96myhge8j756wqm1ez2a1w}, WriteCount=1, AckCount=0
2025-12-12T11:55:26.903097Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 6 to 6
2025-12-12T11:55:26.904258Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.904272Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 6
2025-12-12T11:55:26.922954Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.923029Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { offset: 1 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:26.923037Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:55:26.923041Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:26.923190Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.923207Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written { offset: 2 } } 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:26.923211Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T11:55:26.923214Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:55:26.923241Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.923251Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written { offset: 3 } } 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:26.923254Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId=?
2025-12-12T11:55:26.923257Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:55:26.924774Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=7, txId={ydb://session/3?node_id=1&id=ZWUxYjg5NmUtNWUwYThjN2UtYzhiZTI1ZjItNjE3NDY5NTY=, 01kc96myhge8j756wqm1ez2a1w}, WriteCount=2, AckCount=0
2025-12-12T11:55:26.942631Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 7 to 7
2025-12-12T11:55:26.965518Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.965538Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 7
2025-12-12T11:55:26.973277Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Estimated memory usage 36000000[B] reached maximum (20971520[B])
2025-12-12T11:55:26.984709Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.984782Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 5 written { offset: 4 } } write_statistics { persisting_time { nanos: 15000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:26.984791Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=5, txId=?
2025-12-12T11:55:26.984795Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 5
2025-12-12T11:55:26.984963Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:26.984994Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 6 written_in_tx { } } write_statistics { persisting_time { nanos: 7000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:26.985004Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=6, txId={ydb://session/3?node_id=1&id=ZWUxYjg5NmUtNWUwYThjN2UtYzhiZTI1ZjItNjE3NDY5NTY=, 01kc96myhge8j756wqm1ez2a1w}, WriteCount=2, AckCount=1
2025-12-12T11:55:26.985007Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 6
2025-12-12T11:55:26.985012Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 20000000[B]
2025-12-12T11:55:26.985052Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=8, txId={ydb://session/3?node_id=1&id=ZWUxYjg5NmUtNWUwYThjN2UtYzhiZTI1ZjItNjE3NDY5NTY=, 01kc96myhge8j756wqm1ez2a1w}, WriteCount=3, AckCount=1
2025-12-12T11:55:26.989109Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 8 to 8
2025-12-12T11:55:26.990068Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:26.990082Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 8
2025-12-12T11:55:26.993272Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Estimated memory usage 27000000[B] reached maximum (20971520[B])
2025-12-12T11:55:27.038028Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:27.038097Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 7 written_in_tx { } } write_statistics { persisting_time { nanos: 21000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:27.038110Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=7, txId={ydb://session/3?node_id=1&id=ZWUxYjg5NmUtNWUwYThjN2UtYzhiZTI1ZjItNjE3NDY5NTY=, 01kc96myhge8j756wqm1ez2a1w}, WriteCount=3, AckCount=2
2025-12-12T11:55:27.038116Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 7
2025-12-12T11:55:27.038121Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 7000000[B]
2025-12-12T11:55:27.044424Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:27.044505Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 8 written_in_tx { } } write_statistics { persisting_time { nanos: 9000000 } min_queue_wait_time { nanos: 10000000 } max_queue_wait_time { nanos: 10000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:27.044520Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] OnAck: seqNo=8, txId={ydb://session/3?node_id=1&id=ZWUxYjg5NmUtNWUwYThjN2UtYzhiZTI1ZjItNjE3NDY5NTY=, 01kc96myhge8j756wqm1ez2a1w}, WriteCount=3, AckCount=3
2025-12-12T11:55:27.044817Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 8
2025-12-12T11:55:27.060610Z :INFO: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Starting read session
2025-12-12T11:55:27.060629Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Starting single session
2025-12-12T11:55:27.060935Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:27.060944Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:27.060950Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:27.061233Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Successfully connected. Initializing session
2025-12-12T11:55:27.062318Z :INFO: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1
2025-12-12T11:55:27.062348Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:27.062433Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:27.068581Z :INFO: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_17/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:27.068703Z :DEBUG: [local] 0x00001393BF746010 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:27.068726Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:27.068934Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:27.068940Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:27.068943Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:27.068985Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:27.069039Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_17/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer" }
2025-12-12T11:55:27.069718Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:27.069735Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:27.069738Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:27.069753Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:27.069759Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:27.070139Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_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:27.070149Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:27.166831Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 3
2025-12-12T11:55:27.166851Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:27.167062Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Got ReadResponse, serverBytesSize = 22001182, now ReadSizeBudget = 0, ReadSizeServerDelta = 30427618
2025-12-12T11:55:27.167095Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 30427618
2025-12-12T11:55:27.167167Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:55:27.167167Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-3)
2025-12-12T11:55:27.167206Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 22001182 to budget
2025-12-12T11:55:27.167216Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 22001182, ReadSizeServerDelta = 30427618
2025-12-12T11:55:27.167448Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:27.167479Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:27.176216Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:27.179804Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:55:27.182309Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (2-2)
2025-12-12T11:55:27.182329Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (3-3)
2025-12-12T11:55:27.182345Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] The application data is transferred to the client. Number of messages 4, size 22000600 bytes
2025-12-12T11:55:27.182357Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T11:55:27.184945Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Commit offsets [0, 4). Partition stream id: 1
2025-12-12T11:55:27.189965Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 4 lastOffset = 5
2025-12-12T11:55:27.189984Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:55:27.190187Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Got ReadResponse, serverBytesSize = 16000337, now ReadSizeBudget = 0, ReadSizeServerDelta = 36428463
2025-12-12T11:55:27.190217Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 36428463
2025-12-12T11:55:27.190275Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (4-4)
2025-12-12T11:55:27.190287Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 16000337 to budget
2025-12-12T11:55:27.190291Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 16000337, ReadSizeServerDelta = 36428463
2025-12-12T11:55:27.190304Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (5-5)
2025-12-12T11:55:27.190334Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:27.190349Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:27.191825Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T11:55:27.193816Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-12T11:55:27.193843Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] The application data is transferred to the client. Number of messages 2, size 16000000 bytes
2025-12-12T11:55:27.193858Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:55:27.195972Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Commit offsets [4, 6). Partition stream id: 1
2025-12-12T11:55:27.220893Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 4 } }
2025-12-12T11:55:27.221473Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 6 } }
2025-12-12T11:55:27.226530Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 3 firstOffset = 6 lastOffset = 6
2025-12-12T11:55:27.226552Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Waiting for NextDirectReadId=3. Got DirectReadResponse 3
2025-12-12T11:55:27.226748Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Got ReadResponse, serverBytesSize = 20000185, now ReadSizeBudget = 0, ReadSizeServerDelta = 32428615
2025-12-12T11:55:27.226768Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 32428615
2025-12-12T11:55:27.226829Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-6)
2025-12-12T11:55:27.226853Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 20000185 to budget
2025-12-12T11:55:27.226859Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 20000185, ReadSizeServerDelta = 32428615
2025-12-12T11:55:27.227100Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:27.230197Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 4 firstOffset = 7 lastOffset = 7
2025-12-12T11:55:27.230218Z :DEBUG: [local] 0x00001393BFBC6E20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 NodeId=1 Waiting for NextDirectReadId=4. Got DirectReadResponse 4
2025-12-12T11:55:27.230248Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-12T11:55:27.230279Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] The application data is transferred to the client. Number of messages 1, size 20000000 bytes
2025-12-12T11:55:27.230383Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Got ReadResponse, serverBytesSize = 7000185, now ReadSizeBudget = 0, ReadSizeServerDelta = 45428615
2025-12-12T11:55:27.230406Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 45428615
2025-12-12T11:55:27.245843Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 45428615
2025-12-12T11:55:27.245872Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:27.245874Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 45428615
2025-12-12T11:55:27.245880Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (7-7)
0 2025-12-12T11:55:27.245918Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 7000185 to budget
1
2025-12-12T11:55:27.245935Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] In ContinueReadingDataImpl, ReadSizeBudget = 7000185, ReadSizeServerDelta = 45428615
2025-12-12T11:55:27.246144Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:27.248257Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Commit offsets [6, 7). Partition stream id: 1
2025-12-12T11:55:27.249375Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-12-12T11:55:27.249399Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] The application data is transferred to the client. Number of messages 1, size 7000000 bytes
2025-12-12T11:55:27.249411Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:55:27.249874Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 7 } }
2025-12-12T11:55:27.250151Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Commit offsets [7, 8). Partition stream id: 1
2025-12-12T11:55:27.251526Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 8 } }
2025-12-12T11:55:28.061339Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_17/topic_A:0:1:7:8
2025-12-12T11:55:28.061365Z :INFO: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 65000600 MessagesRead: 8 BytesReadCompressed: 65000600 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:29.060677Z :INFO: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:29.060707Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_17/topic_A:0:1:7:8
2025-12-12T11:55:29.060719Z :INFO: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 65000600 MessagesRead: 8 BytesReadCompressed: 65000600 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:29.060745Z :NOTICE: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:29.060756Z :DEBUG: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] [] Abort session to cluster
2025-12-12T11:55:29.060979Z :DEBUG: [local] 0x00001393BF746010 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 Close
2025-12-12T11:55:29.061008Z :DEBUG: [local] 0x00001393BF746010 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_13038021190146329916_v1 Close
2025-12-12T11:55:29.061025Z :NOTICE: [local] [local] [9b63a5d5-6ceed5fa-de16c7a6-9f64f379] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:29.061203Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:29.061207Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:29.061213Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:29.061311Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:29.061316Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|9d350eef-e6520cf8-efc37fe1-c4471e10_0]  PartitionId [0]  Generation [1] Write session: destroy
