2025-12-12T11:57:50.015184Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:50.015397Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:50.015703Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:50.015752Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_17/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:50.015891Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:50.022394Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.022413Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540670022 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:50.022435Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0"
2025-12-12T11:57:50.022440Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:50.022504Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:50.022551Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:50.023778Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_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:50.023791Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:50.023797Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:50.024039Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:50.024147Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:50.024192Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_17/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:50.024277Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:50.029393Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.029431Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|43c130ba-809f017-e70b4141-f489e306_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0"
2025-12-12T11:57:50.029435Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:50.052436Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:50.078204Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.078237Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:50.105787Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Estimated memory usage 22000000[B] reached maximum (20971520[B])
2025-12-12T11:57:50.197695Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.197766Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 24000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:50.197773Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:50.197778Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:50.197783Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 0[B]
2025-12-12T11:57:50.205060Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:50.205102Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.205110Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:50.205295Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:50.205305Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.205309Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:50.205323Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:50.205332Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.205335Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:50.219730Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 5 to 5
2025-12-12T11:57:50.230542Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.230566Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-12-12T11:57:50.244476Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=6, txId={ydb://session/3?node_id=1&id=YmVhOTM5NGQtZjM1Yjc5OTMtNmEwYWEzMmQtNDM3MGJiMWE=, 01kc96sahe5szbqysfkqyxydz0}, WriteCount=1, AckCount=0
2025-12-12T11:57:50.245849Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 6 to 6
2025-12-12T11:57:50.246988Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.247002Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 6
2025-12-12T11:57:50.255267Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.255339Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_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:57:50.255347Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:50.255351Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:50.255484Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.255498Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_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:57:50.255501Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T11:57:50.255504Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:50.255522Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.255534Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_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:57:50.255537Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId=?
2025-12-12T11:57:50.255539Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:50.264962Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=7, txId={ydb://session/3?node_id=1&id=YmVhOTM5NGQtZjM1Yjc5OTMtNmEwYWEzMmQtNDM3MGJiMWE=, 01kc96sahe5szbqysfkqyxydz0}, WriteCount=2, AckCount=0
2025-12-12T11:57:50.289520Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 7 to 7
2025-12-12T11:57:50.315330Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.315354Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 7
2025-12-12T11:57:50.324314Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Estimated memory usage 36000000[B] reached maximum (20971520[B])
2025-12-12T11:57:50.341196Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.341282Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_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:57:50.341290Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=5, txId=?
2025-12-12T11:57:50.341294Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 5
2025-12-12T11:57:50.341461Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.341476Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_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:57:50.341485Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=6, txId={ydb://session/3?node_id=1&id=YmVhOTM5NGQtZjM1Yjc5OTMtNmEwYWEzMmQtNDM3MGJiMWE=, 01kc96sahe5szbqysfkqyxydz0}, WriteCount=2, AckCount=1
2025-12-12T11:57:50.341489Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 6
2025-12-12T11:57:50.341494Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 20000000[B]
2025-12-12T11:57:50.341547Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=8, txId={ydb://session/3?node_id=1&id=YmVhOTM5NGQtZjM1Yjc5OTMtNmEwYWEzMmQtNDM3MGJiMWE=, 01kc96sahe5szbqysfkqyxydz0}, WriteCount=3, AckCount=1
2025-12-12T11:57:50.346051Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 8 to 8
2025-12-12T11:57:50.346988Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:50.347003Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 8
2025-12-12T11:57:50.349880Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Estimated memory usage 27000000[B] reached maximum (20971520[B])
2025-12-12T11:57:50.401539Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.401596Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 7 written_in_tx { } } write_statistics { persisting_time { nanos: 20000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:50.401607Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=7, txId={ydb://session/3?node_id=1&id=YmVhOTM5NGQtZjM1Yjc5OTMtNmEwYWEzMmQtNDM3MGJiMWE=, 01kc96sahe5szbqysfkqyxydz0}, WriteCount=3, AckCount=2
2025-12-12T11:57:50.401616Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 7
2025-12-12T11:57:50.401622Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 7000000[B]
2025-12-12T11:57:50.407124Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:50.407182Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 8 written_in_tx { } } write_statistics { persisting_time { nanos: 8000000 } min_queue_wait_time { nanos: 8000000 } max_queue_wait_time { nanos: 8000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:50.407191Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=8, txId={ydb://session/3?node_id=1&id=YmVhOTM5NGQtZjM1Yjc5OTMtNmEwYWEzMmQtNDM3MGJiMWE=, 01kc96sahe5szbqysfkqyxydz0}, WriteCount=3, AckCount=3
2025-12-12T11:57:50.407498Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 8
2025-12-12T11:57:50.422389Z :INFO: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Starting read session
2025-12-12T11:57:50.422409Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Starting single session
2025-12-12T11:57:50.422755Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:50.422761Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:50.422767Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:50.423063Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Successfully connected. Initializing session
2025-12-12T11:57:50.424078Z :INFO: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1
2025-12-12T11:57:50.424100Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:50.424204Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:50.432067Z :INFO: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_17/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:50.432246Z :DEBUG: [local] 0x000071673F749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:50.432281Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:50.432601Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:50.432637Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:50.432641Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:50.432715Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:50.432760Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_17/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer" }
2025-12-12T11:57:50.433385Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:50.433400Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:50.433403Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:50.433415Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:50.433421Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:50.433792Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_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:50.433803Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:50.501450Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 3
2025-12-12T11:57:50.501472Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:50.501821Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Got ReadResponse, serverBytesSize = 22001182, now ReadSizeBudget = 0, ReadSizeServerDelta = 30427618
2025-12-12T11:57:50.501852Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 30427618
2025-12-12T11:57:50.501906Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-3)
2025-12-12T11:57:50.501906Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:50.501940Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 22001182 to budget
2025-12-12T11:57:50.501948Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 22001182, ReadSizeServerDelta = 30427618
2025-12-12T11:57:50.501957Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:50.501977Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:50.511843Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:50.520716Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 4 lastOffset = 5
2025-12-12T11:57:50.520739Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:50.520945Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Got ReadResponse, serverBytesSize = 16000337, now ReadSizeBudget = 0, ReadSizeServerDelta = 36428463
2025-12-12T11:57:50.522799Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:50.549621Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (2-2)
2025-12-12T11:57:50.549645Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (3-3)
2025-12-12T11:57:50.549678Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] The application data is transferred to the client. Number of messages 4, size 22000600 bytes
2025-12-12T11:57:50.549719Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 36428463
2025-12-12T11:57:50.549739Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 36428463
2025-12-12T11:57:50.549750Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:50.549753Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 36428463
2025-12-12T11:57:50.549775Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (4-4)
0 42025-12-12T11:57:50.549782Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (5-5)
2025-12-12T11:57:50.549791Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 16000337 to budget
2025-12-12T11:57:50.549809Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 16000337, ReadSizeServerDelta = 36428463
2025-12-12T11:57:50.549983Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:50.549992Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:50.553085Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Commit offsets [0, 4). Partition stream id: 1
2025-12-12T11:57:50.554774Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T11:57:50.555267Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 4 } }
2025-12-12T11:57:50.555539Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 3 firstOffset = 6 lastOffset = 6
2025-12-12T11:57:50.555554Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Waiting for NextDirectReadId=3. Got DirectReadResponse 3
2025-12-12T11:57:50.557006Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-12T11:57:50.557032Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] The application data is transferred to the client. Number of messages 2, size 16000000 bytes
2025-12-12T11:57:50.557194Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Got ReadResponse, serverBytesSize = 20000185, now ReadSizeBudget = 0, ReadSizeServerDelta = 32428615
2025-12-12T11:57:50.557228Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 32428615
2025-12-12T11:57:50.557234Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:50.557238Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 32428615
0 2
2025-12-12T11:57:50.557268Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-6)
2025-12-12T11:57:50.557283Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 20000185 to budget
2025-12-12T11:57:50.557287Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 20000185, ReadSizeServerDelta = 32428615
2025-12-12T11:57:50.557381Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:50.559169Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 4 firstOffset = 7 lastOffset = 7
2025-12-12T11:57:50.559181Z :DEBUG: [local] 0x000071673FBCA520 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 NodeId=1 Waiting for NextDirectReadId=4. Got DirectReadResponse 4
2025-12-12T11:57:50.559311Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Got ReadResponse, serverBytesSize = 7000185, now ReadSizeBudget = 0, ReadSizeServerDelta = 45428615
2025-12-12T11:57:50.559332Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 45428615
2025-12-12T11:57:50.559399Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (7-7)
2025-12-12T11:57:50.559416Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 7000185 to budget
2025-12-12T11:57:50.559423Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] In ContinueReadingDataImpl, ReadSizeBudget = 7000185, ReadSizeServerDelta = 45428615
2025-12-12T11:57:50.559551Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:50.560572Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Commit offsets [4, 6). Partition stream id: 1
2025-12-12T11:57:50.562033Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 6 } }
2025-12-12T11:57:50.582802Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-12T11:57:50.607511Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-12-12T11:57:50.607547Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] The application data is transferred to the client. Number of messages 1, size 7000000 bytes
2025-12-12T11:57:50.607580Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] The application data is transferred to the client. Number of messages 1, size 20000000 bytes
2025-12-12T11:57:50.607586Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:50.607604Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:57:50.611091Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Commit offsets [6, 8). Partition stream id: 1
2025-12-12T11:57:50.612795Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 8 } }
2025-12-12T11:57:51.423352Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_17/topic_A:0:1:7:8
2025-12-12T11:57:51.423388Z :INFO: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 65000600 MessagesRead: 8 BytesReadCompressed: 65000600 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:52.422503Z :INFO: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:52.422534Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_17/topic_A:0:1:7:8
2025-12-12T11:57:52.422545Z :INFO: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 65000600 MessagesRead: 8 BytesReadCompressed: 65000600 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:52.422573Z :NOTICE: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:52.422583Z :DEBUG: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] [] Abort session to cluster
2025-12-12T11:57:52.422844Z :DEBUG: [local] 0x000071673F749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 Close
2025-12-12T11:57:52.422874Z :DEBUG: [local] 0x000071673F749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_17-test-consumer_1_13_16459640620204483322_v1 Close
2025-12-12T11:57:52.422890Z :NOTICE: [local] [local] [d9519ead-52336a05-ff23bbc0-68f8574] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:52.423095Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:52.423106Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:52.423113Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:52.423255Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:52.423262Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d64a70f3-52025981-e50ada12-f43fc53f_0]  PartitionId [0]  Generation [1] Write session: destroy
