2025-12-12T11:57:47.687601Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:57:47.687782Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:47.688020Z :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:47.688060Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:57:47.688138Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:47.694918Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:47.694939Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540667694 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:47.694964Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0"
2025-12-12T11:57:47.694970Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:47.695042Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:47.695096Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:47.696648Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_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:47.696675Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:47.696680Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:47.696968Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:47.697110Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:47.697139Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:57:47.697247Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:47.701959Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:47.701991Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|8c35fee8-fc6d6e7a-d1906aef-7f82f14e_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0"
2025-12-12T11:57:47.701996Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:47.702065Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ODYwYjExYjQtYzM1MTg0NWItYmY5YTIwYzQtNWNmMDYyNzI=, 01kc96s897cyyr2081d9y0t3r7}, WriteCount=1, AckCount=0
2025-12-12T11:57:47.702081Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:47.702104Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:47.702111Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:47.702241Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:47.705040Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:47.705094Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_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:47.705105Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ODYwYjExYjQtYzM1MTg0NWItYmY5YTIwYzQtNWNmMDYyNzI=, 01kc96s897cyyr2081d9y0t3r7}, WriteCount=1, AckCount=1
2025-12-12T11:57:47.705110Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:47.802340Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:47.802368Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:47.802700Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:47.802721Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:47.802739Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:47.802759Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e5aedf4d-48436a23-2e17ed62-9f10c4ac_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:47.803075Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:57:47.803277Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:47.803565Z :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:47.803612Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:57:47.803781Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:47.809726Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:47.809747Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540667809 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:47.809787Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0"
2025-12-12T11:57:47.809792Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:47.809867Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:47.809925Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:47.811111Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_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:47.811124Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:47.811130Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:47.811378Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:47.811464Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:47.811491Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:57:47.811593Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:47.817890Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:47.817925Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|edbc1f7b-52da59c4-2d2d4963-fab2927a_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0"
2025-12-12T11:57:47.817929Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:47.818018Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ODYwYjExYjQtYzM1MTg0NWItYmY5YTIwYzQtNWNmMDYyNzI=, 01kc96s897cyyr2081d9y0t3r7}, WriteCount=1, AckCount=0
2025-12-12T11:57:47.818042Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:47.818067Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:47.818073Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:47.818227Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:47.819956Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:47.820008Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_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:47.820018Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ODYwYjExYjQtYzM1MTg0NWItYmY5YTIwYzQtNWNmMDYyNzI=, 01kc96s897cyyr2081d9y0t3r7}, WriteCount=1, AckCount=1
2025-12-12T11:57:47.820024Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:47.918284Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:47.918307Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:47.918665Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:47.918690Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:47.918706Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:47.918732Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ef292dc7-9a112e62-1a5b8bbd-6eef6086_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:47.921429Z :INFO: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Starting read session
2025-12-12T11:57:47.921443Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Starting single session
2025-12-12T11:57:47.921613Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:47.921617Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:47.921621Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:47.921827Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Successfully connected. Initializing session
2025-12-12T11:57:47.922671Z :INFO: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1
2025-12-12T11:57:47.922684Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:47.922739Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:47.924272Z :INFO: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:47.924364Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:47.924384Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:47.924526Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:47.924533Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:47.924536Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:47.924576Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:47.924632Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer" }
2025-12-12T11:57:47.925185Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:47.925194Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:47.925196Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:47.925205Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:47.925209Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:47.925526Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_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:47.925534Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:47.925666Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:47.925676Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:47.925792Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Got ReadResponse, serverBytesSize = 310, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T11:57:47.925820Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T11:57:47.925865Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:47.925880Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Returning serverBytesSize = 310 to budget
2025-12-12T11:57:47.925886Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] In ContinueReadingDataImpl, ReadSizeBudget = 310, ReadSizeServerDelta = 52428490
2025-12-12T11:57:47.925935Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:47.925990Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:47.925999Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:47.926008Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:47.926014Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:57:47.926030Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:57:47.927209Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:57:48.922330Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A:0:1:1:2
2025-12-12T11:57:48.922362Z :INFO: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:49.921497Z :INFO: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:49.921524Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_15/topic_A:0:1:1:2
2025-12-12T11:57:49.921532Z :INFO: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:49.921554Z :NOTICE: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:49.921564Z :DEBUG: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] [] Abort session to cluster
2025-12-12T11:57:49.921894Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 Close
2025-12-12T11:57:49.922157Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_16917374728159110302_v1 Close
2025-12-12T11:57:49.922185Z :NOTICE: [local] [local] [505a93ea-9f3859c0-a7749296-762121b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
