2025-12-12T12:00:28.945253Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T12:00:28.945456Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:28.945485Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:28.946559Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:28.946573Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:28.946579Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:28.946750Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:28.946782Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T12:00:28.946951Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:28.955198Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.955235Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540828955 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:28.955265Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0"
2025-12-12T12:00:28.955350Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=1, AckCount=0
2025-12-12T12:00:28.955557Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:28.955722Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.955733Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:28.957978Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=0
2025-12-12T12:00:28.958170Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:28.958321Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.958330Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:28.959183Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T12:00:28.959445Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:28.959483Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:28.960704Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:28.960721Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:28.960726Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:28.960940Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:28.960975Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_3" partition_with_generation { generation: 1 } }
2025-12-12T12:00:28.961110Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:28.963231Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.963300Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.963313Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=1
2025-12-12T12:00:28.963318Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:28.964758Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.964795Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { nanos: 2000000 } max_queue_wait_time { nanos: 2000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.964804Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=2
2025-12-12T12:00:28.964808Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:28.967657Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.967673Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540828967 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:28.967694Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0"
2025-12-12T12:00:28.967759Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=1, AckCount=0
2025-12-12T12:00:28.967951Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:28.968108Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.968117Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:28.968895Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=0
2025-12-12T12:00:28.969042Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:28.969170Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.969175Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:28.969830Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Write session: try to update token
2025-12-12T12:00:28.970097Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Get partition location async, partition 1, delay 0.000000s
2025-12-12T12:00:28.970152Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0]  Getting partition location, partition 1
2025-12-12T12:00:28.971293Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  partition_id: 1
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:28.971307Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] GetPreferredEndpoint: partitionId 1, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:28.971313Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:28.971488Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: direct write to partition: 1, generation 1
2025-12-12T12:00:28.971535Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { partition_id: 1 generation: 1 } }
2025-12-12T12:00:28.971646Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:28.973423Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.973479Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.973495Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=1
2025-12-12T12:00:28.973504Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:28.975336Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.975404Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { nanos: 2000000 } max_queue_wait_time { nanos: 2000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.975414Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=2
2025-12-12T12:00:28.975419Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:28.979170Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.979189Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540828979 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:28.979215Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0" partition_id: 1
2025-12-12T12:00:28.979302Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=1, AckCount=0
2025-12-12T12:00:28.979502Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:28.979674Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.979688Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:28.980554Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=0
2025-12-12T12:00:28.980709Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:28.980842Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.980849Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:28.981599Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Write session: try to update token
2025-12-12T12:00:28.981880Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Get partition location async, partition 1, delay 0.000000s
2025-12-12T12:00:28.981920Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0]  Getting partition location, partition 1
2025-12-12T12:00:28.983299Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  partition_id: 1
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:28.983313Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] GetPreferredEndpoint: partitionId 1, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:28.983319Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:28.983574Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: direct write to partition: 1, generation 1
2025-12-12T12:00:28.983604Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_4" partition_with_generation { partition_id: 1 generation: 1 } }
2025-12-12T12:00:28.983690Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:28.986836Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.986882Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.986892Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=1
2025-12-12T12:00:28.986895Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:28.988687Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.988719Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { nanos: 2000000 } max_queue_wait_time { nanos: 2000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.988725Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=2
2025-12-12T12:00:28.988728Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:28.990016Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.990035Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540828990 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:28.990047Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0" partition_id: 1
2025-12-12T12:00:28.990128Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=1, AckCount=0
2025-12-12T12:00:28.990309Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:28.990498Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.990507Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:28.991355Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=0
2025-12-12T12:00:28.991505Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:28.991636Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:28.991643Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:28.995437Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.995482Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.995492Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=1
2025-12-12T12:00:28.995496Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:28.997275Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:28.997326Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:28.997336Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YWI2MjIxOTMtM2EyZGJiYzEtYjNlNjAwNS00NjczOGU5ZA==, 01kc96y5rg451q79ywsk0hkaag}, WriteCount=2, AckCount=2
2025-12-12T12:00:28.997606Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:59.109194Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:59.109210Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session will now close
2025-12-12T12:00:59.109216Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: aborting
2025-12-12T12:00:59.109376Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:59.109382Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b5af0f4-2d2a8c8f-d41cd68e-1590574_0]  PartitionId [1]  Generation [1] Write session: destroy
2025-12-12T12:00:59.109607Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:59.109622Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:59.109626Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:59.109716Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:59.109719Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|f7e6d8fa-e9fb317-bc17fee3-42ebcc7c_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:00:59.109932Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:59.109937Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session will now close
2025-12-12T12:00:59.109941Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: aborting
2025-12-12T12:00:59.110020Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:59.110024Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|1ce5659-659e6f33-e0a1c9a8-41e6ebb_0]  PartitionId [1]  Generation [1] Write session: destroy
2025-12-12T12:00:59.110215Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:59.110219Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:59.110222Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:59.110368Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:59.110390Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:59.110403Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T12:00:59.110422Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|86ccb220-6aebb85-ed88d62b-e1b5da3b_0]  PartitionId [0]  Generation [1] Write session: destroy
