2025-12-12T11:57:38.694506Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:38.694667Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:38.694854Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:38.694894Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:38.694978Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:38.701344Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.701365Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540658701 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:38.701403Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0"
2025-12-12T11:57:38.701407Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:38.701488Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:38.701549Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:38.703029Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:38.703045Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:38.703050Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:38.703366Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:38.703504Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:38.703539Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:38.703647Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:38.710695Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.710748Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d3dd6180-54e8acb7-4daef787-c397fff5_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0"
2025-12-12T11:57:38.710756Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:38.710833Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzg62r4rhqk1gyfhdgxj}, WriteCount=1, AckCount=0
2025-12-12T11:57:38.710856Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:38.710881Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:38.710888Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:38.711072Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:38.711332Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:38.711586Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:38.711616Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:38.711720Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:38.714369Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.714424Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:38.714438Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzg62r4rhqk1gyfhdgxj}, WriteCount=1, AckCount=1
2025-12-12T11:57:38.714444Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:38.718957Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.718988Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540658718 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:38.719013Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0"
2025-12-12T11:57:38.719017Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:38.719080Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:38.719145Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:38.720765Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:38.720785Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:38.720790Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:38.721158Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:38.721275Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:38.721309Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:38.721413Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:38.728069Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.728122Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|61f92644-3436259d-cefc67f7-13698758_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0"
2025-12-12T11:57:38.728127Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:38.728221Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzg62r4rhqk1gyfhdgxj}, WriteCount=1, AckCount=0
2025-12-12T11:57:38.728241Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:38.728261Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:38.728269Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:38.731808Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.731861Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:38.731876Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzg62r4rhqk1gyfhdgxj}, WriteCount=1, AckCount=1
2025-12-12T11:57:38.732158Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:38.746086Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzhsarht4dk4z3dshvwt}, WriteCount=1, AckCount=0
2025-12-12T11:57:38.746120Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:38.746145Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:38.746151Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:38.746285Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzhsarht4dk4z3dshvwt}, WriteCount=1, AckCount=0
2025-12-12T11:57:38.746292Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:38.746299Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:38.746303Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:38.749692Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.749756Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_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:57:38.749769Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzhsarht4dk4z3dshvwt}, WriteCount=1, AckCount=1
2025-12-12T11:57:38.749789Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:38.756837Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:38.756923Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_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 { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:38.756940Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YTQ2OTAwMi1jM2U4YTYwOC1jNjc4MTA2Zi00ODIxYzkzNg==, 01kc96rzhsarht4dk4z3dshvwt}, WriteCount=1, AckCount=1
2025-12-12T11:57:38.757288Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:38.764378Z :INFO: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Starting read session
2025-12-12T11:57:38.764396Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Starting single session
2025-12-12T11:57:38.764698Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:38.764705Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:38.764711Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:38.765014Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Successfully connected. Initializing session
2025-12-12T11:57:38.766073Z :INFO: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1
2025-12-12T11:57:38.766094Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:38.766166Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:38.768211Z :INFO: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:38.768325Z :DEBUG: [local] 0x0000514CBF749410 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:38.768346Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:38.768610Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:38.768622Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:38.768625Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:38.770669Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:38.770723Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic-test-consumer" }
2025-12-12T11:57:38.771565Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:38.771577Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:38.771582Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:38.771595Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:38.771601Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:38.772003Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:38.772017Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:38.772127Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:38.772138Z :DEBUG: [local] 0x0000514CBF60B5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:38.772289Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Got ReadResponse, serverBytesSize = 306, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:57:38.772324Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:57:38.772367Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:38.772391Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Returning serverBytesSize = 306 to budget
2025-12-12T11:57:38.772397Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] In ContinueReadingDataImpl, ReadSizeBudget = 306, ReadSizeServerDelta = 52428494
2025-12-12T11:57:38.772484Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:38.772546Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:38.772559Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:38.772571Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:38.772580Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:57:38.772597Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:57:38.773907Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:57:39.765367Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_A:0:1:1:2
2025-12-12T11:57:39.765396Z :INFO: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.764464Z :INFO: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Starting read session
2025-12-12T11:57:40.764483Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Starting single session
2025-12-12T11:57:40.764735Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.764741Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.764746Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:40.765090Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Successfully connected. Initializing session
2025-12-12T11:57:40.766136Z :INFO: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1
2025-12-12T11:57:40.766156Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.766197Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.767622Z :INFO: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:40.767712Z :DEBUG: [local] 0x0000514CBF74AE10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:40.767732Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:40.767913Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:40.767918Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.767920Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:40.767941Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:40.767989Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_B" } consumer: "TxUsageQuery-DirectRead_WriteToTopic-test-consumer" }
2025-12-12T11:57:40.768505Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:40.768513Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:40.768517Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.768532Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.768538Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.768836Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.768847Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:40.768974Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:40.768985Z :DEBUG: [local] 0x0000514CBF605820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:40.769098Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Got ReadResponse, serverBytesSize = 306, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:57:40.769122Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:57:40.769157Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:40.769176Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Returning serverBytesSize = 306 to budget
2025-12-12T11:57:40.769182Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] In ContinueReadingDataImpl, ReadSizeBudget = 306, ReadSizeServerDelta = 52428494
2025-12-12T11:57:40.769222Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.769267Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:40.769278Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:40.769289Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:40.769297Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:57:40.769320Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:57:40.770515Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:57:41.765376Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_B:0:1:1:2
2025-12-12T11:57:41.765399Z :INFO: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.764529Z :INFO: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:42.764561Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_B:0:1:1:2
2025-12-12T11:57:42.764573Z :INFO: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.764609Z :NOTICE: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:42.764621Z :DEBUG: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] [] Abort session to cluster
2025-12-12T11:57:42.764954Z :DEBUG: [local] 0x0000514CBF74AE10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 Close
2025-12-12T11:57:42.765109Z :DEBUG: [local] 0x0000514CBF74AE10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_19_3563938770561173132_v1 Close
2025-12-12T11:57:42.765134Z :NOTICE: [local] [local] [db985400-41318fa7-2c946dd0-60214e77] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:42.765667Z :INFO: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:42.765681Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic/topic_A:0:1:1:2
2025-12-12T11:57:42.765689Z :INFO: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4001 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.765700Z :NOTICE: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:42.765706Z :DEBUG: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] [] Abort session to cluster
2025-12-12T11:57:42.765804Z :DEBUG: [local] 0x0000514CBF749410 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 Close
2025-12-12T11:57:42.765838Z :DEBUG: [local] 0x0000514CBF749410 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic-test-consumer_1_17_8600851222847051546_v1 Close
2025-12-12T11:57:42.765850Z :NOTICE: [local] [local] [43673a9b-8cf60595-dede140a-1f357747] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:42.766004Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:42.766008Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:42.766013Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:42.766091Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:42.766096Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ec8c8d5-825ccb2d-f409ddc-9aab6f06_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:42.766310Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:42.766316Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:42.766320Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:42.766343Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:42.766346Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff5cc61-f3f67859-92c6abdc-381c2b78_0]  PartitionId [0]  Generation [1] Write session: destroy
