2025-12-12T11:57:30.712539Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:57:30.712764Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:30.713098Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T11:57:30.714757Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:57:30.714910Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.304948Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.304972Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540651304 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:31.305008Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0"
2025-12-12T11:57:31.305014Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.305072Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:31.305134Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:31.306542Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_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:31.306557Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:31.306562Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:31.306808Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:31.306841Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:57:31.306929Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:31.306957Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.311789Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.311821Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c7c3fca1-b5269b7c-c8619cff-4cc8fb6d_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0"
2025-12-12T11:57:31.311826Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.311900Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=1, AckCount=0
2025-12-12T11:57:31.311914Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:31.311947Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.311951Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:31.312070Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=2, AckCount=0
2025-12-12T11:57:31.312074Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:31.312078Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.312080Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:31.312084Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=3, AckCount=0
2025-12-12T11:57:31.312087Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:31.312091Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.312093Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:31.312296Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=4, AckCount=0
2025-12-12T11:57:31.312310Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:31.312321Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.312326Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:31.312451Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:57:31.312693Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:31.312984Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T11:57:31.313016Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:57:31.313120Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.315375Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.315543Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_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:31.315556Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=4, AckCount=1
2025-12-12T11:57:31.315561Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:31.316059Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.316091Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.316098Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=4, AckCount=2
2025-12-12T11:57:31.316102Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:31.316137Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.316150Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.316154Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=4, AckCount=3
2025-12-12T11:57:31.316156Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:31.316192Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.316207Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.316211Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=4, AckCount=4
2025-12-12T11:57:31.316214Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:31.318803Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.318816Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540651318 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:31.318829Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0"
2025-12-12T11:57:31.318833Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.318874Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:31.318910Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:31.319906Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_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:31.319917Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:31.319922Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:31.320156Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:31.320291Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:31.320313Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:57:31.320389Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.325014Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.325041Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|85f302c-e075602f-efd5706d-9f9d077f_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0"
2025-12-12T11:57:31.325045Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.325091Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:31.325118Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.325122Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:31.325276Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:57:31.325470Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:31.325649Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T11:57:31.325684Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:57:31.325767Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.326342Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.326365Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.326369Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:31.326372Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:31.332325Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.332343Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540651332 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:31.332369Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0"
2025-12-12T11:57:31.332372Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.332431Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:31.332475Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:31.333714Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_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:31.333728Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:31.333732Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:31.333980Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:31.334088Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:31.334122Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:57:31.334215Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.340715Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.340747Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|742e0d5-adf77ef6-b5dcb5f-c9900ffe_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0"
2025-12-12T11:57:31.340752Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.340805Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:31.340835Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.340842Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:31.340993Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:57:31.341179Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:31.341375Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T11:57:31.341404Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:57:31.341496Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.342513Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.342549Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.342555Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:31.342559Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:31.346928Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.346964Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540651346 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:31.346994Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0"
2025-12-12T11:57:31.346999Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.347115Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:31.347158Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:31.348281Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_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:31.348292Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:31.348299Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:31.348546Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:31.348650Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:31.348669Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:57:31.348746Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:31.355089Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.355139Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|a3001749-ffcf43e1-aebde833-4e64a6c1_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0"
2025-12-12T11:57:31.355143Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:31.355215Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=1, AckCount=0
2025-12-12T11:57:31.355249Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:31.355268Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.355272Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:31.355373Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=2, AckCount=0
2025-12-12T11:57:31.355376Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:31.355380Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.355382Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:31.355387Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=3, AckCount=0
2025-12-12T11:57:31.355392Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:31.355395Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:31.355396Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:31.355439Z :INFO: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Starting read session
2025-12-12T11:57:31.355443Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Starting single session
2025-12-12T11:57:31.355682Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:31.355686Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:31.355689Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:31.355937Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Successfully connected. Initializing session
2025-12-12T11:57:31.356832Z :INFO: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1
2025-12-12T11:57:31.356851Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:31.356909Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:31.357930Z :INFO: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:31.358009Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:31.358024Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:31.358172Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:31.358176Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:31.358178Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:31.358219Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:31.358259Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer" }
2025-12-12T11:57:31.358308Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.358351Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_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:31.358361Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=3, AckCount=1
2025-12-12T11:57:31.358366Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:31.358906Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.358930Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.358935Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=3, AckCount=2
2025-12-12T11:57:31.358938Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:31.358993Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:31.359006Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:31.359009Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:31.359014Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:31.359019Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:31.359025Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:31.359026Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:31.359046Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=OWViZDhiMmItN2M3ZTMyNDItNzNlMjY0NTMtZDMxOTBlYjE=, 01kc96rqpj04jmjaddn4qerjbd}, WriteCount=3, AckCount=3
2025-12-12T11:57:31.359049Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:31.359379Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_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:31.359388Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:31.359547Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:31.359558Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:31.359668Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Got ReadResponse, serverBytesSize = 166, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:57:31.359689Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:57:31.359748Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:31.359782Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Returning serverBytesSize = 166 to budget
2025-12-12T11:57:31.359789Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] In ContinueReadingDataImpl, ReadSizeBudget = 166, ReadSizeServerDelta = 52428634
2025-12-12T11:57:31.359970Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:31.360034Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:31.360052Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:31.360059Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:31.360074Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:57:31.361118Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:57:32.356303Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A:0:1:0:1
2025-12-12T11:57:32.356330Z :INFO: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:33.355541Z :INFO: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Starting read session
2025-12-12T11:57:33.355559Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Starting single session
2025-12-12T11:57:33.355787Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:33.355795Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:33.355799Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:33.356116Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Successfully connected. Initializing session
2025-12-12T11:57:33.357083Z :INFO: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1
2025-12-12T11:57:33.357106Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:33.357159Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:33.358441Z :INFO: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:33.358553Z :DEBUG: [local] 0x000071673F740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:33.358574Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:33.358751Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:33.358756Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:33.358758Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:33.358801Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:33.358850Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer" }
2025-12-12T11:57:33.359352Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:33.359360Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:33.359363Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:33.359376Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:33.359382Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:33.359756Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_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:33.359768Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:33.359829Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:33.359834Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:33.359918Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Got ReadResponse, serverBytesSize = 166, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:57:33.359939Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428634
2025-12-12T11:57:33.360017Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:33.360044Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Returning serverBytesSize = 166 to budget
2025-12-12T11:57:33.360051Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] In ContinueReadingDataImpl, ReadSizeBudget = 166, ReadSizeServerDelta = 52428634
2025-12-12T11:57:33.360234Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:33.360282Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:33.360296Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:33.360303Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:33.360318Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:57:33.361436Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:57:34.356326Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B:0:1:0:1
2025-12-12T11:57:34.356354Z :INFO: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:35.362975Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 3
2025-12-12T11:57:35.362996Z :DEBUG: [local] 0x000071673FBC4D20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:35.363044Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 4
2025-12-12T11:57:35.363058Z :DEBUG: [local] 0x000071673FBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:35.363126Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Got ReadResponse, serverBytesSize = 463, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428337
2025-12-12T11:57:35.363142Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Got ReadResponse, serverBytesSize = 607, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428193
2025-12-12T11:57:35.363162Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428337
2025-12-12T11:57:35.363162Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428193
2025-12-12T11:57:35.363232Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-3)
2025-12-12T11:57:35.363252Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-4)
2025-12-12T11:57:35.363267Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Returning serverBytesSize = 463 to budget
2025-12-12T11:57:35.363279Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] In ContinueReadingDataImpl, ReadSizeBudget = 463, ReadSizeServerDelta = 52428337
2025-12-12T11:57:35.363283Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Returning serverBytesSize = 607 to budget
2025-12-12T11:57:35.363290Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] In ContinueReadingDataImpl, ReadSizeBudget = 607, ReadSizeServerDelta = 52428193
2025-12-12T11:57:35.363379Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:35.363438Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:35.363454Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:35.363455Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-12-12T11:57:35.363473Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (3-3)
2025-12-12T11:57:35.363478Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (4-4)
2025-12-12T11:57:35.363491Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] The application data is transferred to the client. Number of messages 4, size 40 bytes
2025-12-12T11:57:35.363501Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T11:57:35.363530Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Commit offsets [1, 5). Partition stream id: 1
2025-12-12T11:57:35.364794Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 5 } }
2025-12-12T11:57:37.363048Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:37.363071Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-12-12T11:57:37.363078Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (3-3)
2025-12-12T11:57:37.363093Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:57:37.363105Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:57:37.363135Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Commit offsets [1, 4). Partition stream id: 1
2025-12-12T11:57:37.364876Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 4 } }
2025-12-12T11:57:39.363149Z :INFO: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:39.363174Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_B:0:1:3:4
2025-12-12T11:57:39.363184Z :INFO: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6007 BytesRead: 40 MessagesRead: 4 BytesReadCompressed: 40 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:39.363206Z :NOTICE: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:39.363216Z :DEBUG: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] [] Abort session to cluster
2025-12-12T11:57:39.363422Z :DEBUG: [local] 0x000071673F740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 Close
2025-12-12T11:57:39.363451Z :DEBUG: [local] 0x000071673F740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_3_8863954158886989772_v1 Close
2025-12-12T11:57:39.363466Z :NOTICE: [local] [local] [8a456978-317abb7e-437fd2cd-1d23b85a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:39.363633Z :INFO: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:39.363641Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_2/topic_A:0:1:4:5
2025-12-12T11:57:39.363646Z :INFO: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8008 BytesRead: 50 MessagesRead: 5 BytesReadCompressed: 50 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:39.363653Z :NOTICE: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:39.363658Z :DEBUG: [local] [local] [85d4ee36-56330348-96622b26-724759aa] [] Abort session to cluster
2025-12-12T11:57:39.363678Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 Close
2025-12-12T11:57:39.363694Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_2-test-consumer_1_1_2524014962131012765_v1 Close
2025-12-12T11:57:39.363701Z :NOTICE: [local] [local] [85d4ee36-56330348-96622b26-724759aa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:39.363968Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:39.363980Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:39.363985Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:39.364154Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:39.364159Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|49745e9b-755ee3ed-ca4b5b84-b358cc0f_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:39.364365Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:39.364370Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:39.364373Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:39.364393Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:39.364395Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6e2d0aca-7ae5afab-4e327093-aac726a6_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:39.364626Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:39.364637Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:39.364643Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:39.364774Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:39.364779Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|9818f0ff-74982cfa-6d23fc34-5e21193_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:39.365011Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:39.365015Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:39.365020Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:39.365113Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:39.365117Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|82bbe118-87199967-ca4f5204-b97cf38c_0]  PartitionId [0]  Generation [1] Write session: destroy
