2025-12-12T11:57:39.451831Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:39.452015Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:39.452218Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:39.452251Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:39.452336Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:39.458690Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.458712Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540659458 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:39.458735Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0"
2025-12-12T11:57:39.458739Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:39.458797Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:39.458827Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:39.459869Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_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:39.459883Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:39.459888Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:39.460231Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:39.460357Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:39.460383Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:39.460496Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:39.464939Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.464984Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a7cb5e83-3e06f06a-be42f1d8-bf291094_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0"
2025-12-12T11:57:39.464989Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:39.465046Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s07vb9srxg485mafxh4z}, WriteCount=1, AckCount=0
2025-12-12T11:57:39.465059Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:39.465074Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:39.465079Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:39.465227Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:39.465424Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:39.465628Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:39.465659Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:39.465767Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:39.467966Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.468009Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_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:39.468019Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s07vb9srxg485mafxh4z}, WriteCount=1, AckCount=1
2025-12-12T11:57:39.468023Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:39.470861Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.470876Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540659470 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:39.470901Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0"
2025-12-12T11:57:39.470905Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:39.470955Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:39.470989Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:39.472044Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_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:39.472054Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:39.472058Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:39.472308Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:39.472419Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:39.472446Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:39.472554Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:39.477517Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.477553Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|42dd803c-884c6ea9-8ccd3afa-b10e6b1b_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0"
2025-12-12T11:57:39.477559Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:39.477629Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s07vb9srxg485mafxh4z}, WriteCount=1, AckCount=0
2025-12-12T11:57:39.477647Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:39.477683Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:39.477688Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:39.477794Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:39.477800Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:39.477802Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:39.477902Z :INFO: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Starting read session
2025-12-12T11:57:39.477907Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Starting single session
2025-12-12T11:57:39.478125Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:39.478131Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:39.478134Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:39.478371Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Successfully connected. Initializing session
2025-12-12T11:57:39.479117Z :INFO: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1
2025-12-12T11:57:39.479133Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:39.479230Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:39.479338Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.479374Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 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:39.479379Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:39.479382Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:39.480304Z :INFO: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:39.480352Z :DEBUG: [local] 0x000071673F74BB10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:39.480370Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:39.480459Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:39.480485Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_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:39.480495Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s07vb9srxg485mafxh4z}, WriteCount=1, AckCount=1
2025-12-12T11:57:39.480498Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:39.480553Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:39.480560Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:39.480563Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:39.480596Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:39.480617Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer" }
2025-12-12T11:57:39.481127Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:39.481136Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:39.481138Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:39.481145Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:39.481149Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:39.481457Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_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:39.481465Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:39.481530Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:39.481541Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:39.481674Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:39.481697Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:39.481763Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:39.481800Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:57:39.481808Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:57:39.481982Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:39.482034Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:39.482046Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:39.482053Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:39.482068Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:57:39.483252Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:57:40.478331Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_A:0:1:0:1
2025-12-12T11:57:40.478358Z :INFO: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:41.484210Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s27b3re2p9ryavx1nhwp}, WriteCount=1, AckCount=0
2025-12-12T11:57:41.484231Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:41.484251Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:41.484257Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:41.484351Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s27b3re2p9ryavx1nhwp}, WriteCount=1, AckCount=0
2025-12-12T11:57:41.484356Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:41.484362Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:41.484365Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:41.487493Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:41.487553Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:41.487565Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s27b3re2p9ryavx1nhwp}, WriteCount=1, AckCount=1
2025-12-12T11:57:41.487570Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:41.495629Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:41.495689Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_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 { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:41.495698Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=ZGY1OTE4YmUtYzVjOTVmNDktODZlNmY0ZjEtYzAwNzQ4YmI=, 01kc96s27b3re2p9ryavx1nhwp}, WriteCount=1, AckCount=1
2025-12-12T11:57:41.495971Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:41.504547Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 1
2025-12-12T11:57:41.504569Z :DEBUG: [local] 0x000071673FBC68A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:41.504715Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:41.504738Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:41.504779Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T11:57:41.504803Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:57:41.504811Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:57:41.504905Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:41.504948Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:41.504964Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:41.504970Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:41.504988Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Commit offsets [1, 2). Partition stream id: 1
2025-12-12T11:57:41.505791Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:57:43.504661Z :INFO: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Starting read session
2025-12-12T11:57:43.504677Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Starting single session
2025-12-12T11:57:43.504882Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:43.504886Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:43.504889Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:43.505267Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Successfully connected. Initializing session
2025-12-12T11:57:43.506151Z :INFO: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1
2025-12-12T11:57:43.506171Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:43.506227Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:43.507761Z :INFO: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:43.507899Z :DEBUG: [local] 0x000071673F740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:43.507924Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:43.508166Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:43.508191Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:43.508196Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:43.508224Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:43.508270Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_B" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer" }
2025-12-12T11:57:43.508875Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:43.508885Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:43.508888Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:43.508903Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:43.508909Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:43.509288Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_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:43.509300Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:43.509358Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:43.509362Z :DEBUG: [local] 0x000071673FBC3720 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:43.509477Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:43.509500Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:43.509596Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:43.509629Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:57:43.509640Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:57:43.509810Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:43.509867Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:43.509882Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:43.509890Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:43.509905Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:57:43.511220Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:57:44.505379Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_B:0:1:0:1
2025-12-12T11:57:44.505409Z :INFO: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:45.504732Z :INFO: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:45.504762Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_B:0:1:0:1
2025-12-12T11:57:45.504773Z :INFO: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:45.504796Z :NOTICE: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:45.504806Z :DEBUG: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] [] Abort session to cluster
2025-12-12T11:57:45.505038Z :DEBUG: [local] 0x000071673F740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 Close
2025-12-12T11:57:45.505070Z :DEBUG: [local] 0x000071673F740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_607716244964703245_v1 Close
2025-12-12T11:57:45.505087Z :NOTICE: [local] [local] [e32a70e9-450c4adf-1c8e086f-895ca17a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:45.505249Z :INFO: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:45.505257Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_3/topic_A:0:1:1:2
2025-12-12T11:57:45.505262Z :INFO: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6027 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:45.505269Z :NOTICE: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:45.505274Z :DEBUG: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] [] Abort session to cluster
2025-12-12T11:57:45.505326Z :DEBUG: [local] 0x000071673F74BB10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 Close
2025-12-12T11:57:45.505343Z :DEBUG: [local] 0x000071673F74BB10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_14829138978015113190_v1 Close
2025-12-12T11:57:45.505351Z :NOTICE: [local] [local] [8a907a3d-1ba802aa-2d537b06-980e4695] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:45.505576Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:45.505582Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:45.505588Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:45.505690Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:45.505696Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|632130d3-e0f17c58-2e0c3f81-d7be890b_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:45.505927Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:45.505932Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:45.505936Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:45.506012Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:45.506016Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|660efa0e-9b068993-ec1fc19f-78ecfd58_0]  PartitionId [0]  Generation [1] Write session: destroy
