2025-12-12T11:57:39.684487Z :INFO: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] Starting read session
2025-12-12T11:57:39.684502Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] Starting single session
2025-12-12T11:57:39.684710Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:39.684715Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:39.684718Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:39.689734Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Successfully connected. Initializing session
2025-12-12T11:57:39.691198Z :INFO: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1
2025-12-12T11:57:39.691220Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:39.691282Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:39.699472Z :INFO: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:39.699612Z :DEBUG: [local] 0x000073AEFF746D10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:39.699633Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:39.699850Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:39.699856Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:39.699859Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:39.699946Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:39.699967Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:39.700168Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:39.701231Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" } consumer: "TxUsageTable-DirectRead_SessionAbort-test-consumer" }
2025-12-12T11:57:39.701512Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:39.701527Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:39.701577Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:39.702034Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:39.702044Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:39.702046Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:39.702055Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:39.702059Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:39.702358Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_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.702367Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:40.292480Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.292503Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540660292 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.292533Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0"
2025-12-12T11:57:40.292538Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.292570Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:40.292631Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:40.293986Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_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:40.294021Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:40.294027Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:40.294325Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.294551Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:40.294576Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:40.294687Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.295555Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.295592Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|cd700d0a-a9c9aa8e-9e49d2bc-6a19f8d1_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0"
2025-12-12T11:57:40.295597Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.295669Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:40.295708Z :INFO: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:40.296006Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.296020Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:40.297669Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.297832Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_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:40.297842Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:40.297846Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:40.297984Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:40.297996Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:40.298123Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.298145Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.298232Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:40.298249Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:40.298254Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.298375Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.395811Z :INFO: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:40.395834Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:40.396170Z :INFO: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:40.396199Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.396214Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:40.396236Z :DEBUG: [local]  TraceId []  SessionId [f4743090-c346bba-b081f653-d97eb37e|258710b1-1409b988-9fee3529-972ad417_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:40.396473Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:40.396484Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:40.396492Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:40.396553Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:40.396682Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:40.397517Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:40.397553Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:40.397639Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.403840Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.403860Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540660403 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.403888Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0"
2025-12-12T11:57:40.403893Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.404000Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:40.404057Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:40.405346Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_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:40.405368Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:40.405373Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:40.405690Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.405899Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:40.405927Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:40.406033Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.407023Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.407042Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a03b85de-34d4197a-893f9b78-db35681e_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0"
2025-12-12T11:57:40.407047Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.407100Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:40.407136Z :INFO: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:40.407316Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.407327Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:40.408964Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.409007Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { offset: 1 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:40.409014Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:40.409021Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:40.409258Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 1
2025-12-12T11:57:40.409269Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:40.409426Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.409449Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.409526Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T11:57:40.409545Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:40.409551Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.409662Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.507229Z :INFO: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:40.507255Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:40.507524Z :INFO: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:40.507536Z :DEBUG: [local]  TraceId []  SessionId [1579a91a-de05390a-443c9f5e-e89a83f6|a29e4521-6634b78c-6e764277-c3b6482d_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:40.507706Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:40.507721Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:40.507732Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:40.507787Z :INFO: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:40.507796Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic:0:1:1:0
2025-12-12T11:57:40.507803Z :INFO: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] Counters: { Errors: 0 CurrentSessionLifetimeMs: 823 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.507819Z :NOTICE: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:40.507826Z :DEBUG: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] [] Abort session to cluster
2025-12-12T11:57:40.507949Z :DEBUG: [local] 0x000073AEFF746D10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 Close
2025-12-12T11:57:40.507976Z :DEBUG: [local] 0x000073AEFF746D10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_1_17224757980086854755_v1 Close
2025-12-12T11:57:40.507990Z :NOTICE: [local] [local] [ec68e865-c6bf3877-a8ef4e32-58ae6b04] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:40.509287Z :INFO: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] Starting read session
2025-12-12T11:57:40.509295Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] Starting single session
2025-12-12T11:57:40.509442Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.509446Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.509449Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:40.509614Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Successfully connected. Initializing session
2025-12-12T11:57:40.510457Z :INFO: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1
2025-12-12T11:57:40.510475Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.510543Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.511921Z :INFO: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:40.512022Z :DEBUG: [local] 0x000073AEFF743910 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:40.512039Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:40.512206Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:40.512213Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.512218Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:40.512255Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:40.512301Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" } consumer: "TxUsageTable-DirectRead_SessionAbort-test-consumer" }
2025-12-12T11:57:40.512828Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:40.512838Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:40.512841Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.512852Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.512858Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.513177Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_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:40.513190Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:40.513246Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:40.513251Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:40.513348Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Got ReadResponse, serverBytesSize = 302, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428498
2025-12-12T11:57:40.513370Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428498
2025-12-12T11:57:40.513456Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:40.513486Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Returning serverBytesSize = 302 to budget
2025-12-12T11:57:40.513491Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] In ContinueReadingDataImpl, ReadSizeBudget = 302, ReadSizeServerDelta = 52428498
2025-12-12T11:57:40.513627Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.513688Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:40.513699Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:40.513710Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:40.513719Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:40.517176Z :INFO: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:40.517200Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic:0:1:1:0
2025-12-12T11:57:40.517208Z :INFO: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] Counters: { Errors: 0 CurrentSessionLifetimeMs: 7 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.517225Z :NOTICE: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:40.517231Z :DEBUG: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] [] Abort session to cluster
2025-12-12T11:57:40.517368Z :DEBUG: [local] 0x000073AEFF743910 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 Close
2025-12-12T11:57:40.517390Z :DEBUG: [local] 0x000073AEFF743910 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_3_7283471501655357521_v1 Close
2025-12-12T11:57:40.517403Z :NOTICE: [local] [local] [a2585afb-ccfa0fc0-b7e91ae1-12fd9763] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:40.517615Z :INFO: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] Starting read session
2025-12-12T11:57:40.517633Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] Starting single session
2025-12-12T11:57:40.517789Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.517794Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.517798Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:40.518031Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] Successfully connected. Initializing session
2025-12-12T11:57:40.518709Z :INFO: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1
2025-12-12T11:57:40.518723Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.518766Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.519865Z :INFO: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:40.519948Z :DEBUG: [local] 0x000073AEFF743910 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:40.519961Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:40.520081Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:40.520087Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.520090Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:40.520098Z :INFO: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:40.520106Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic:0:1:0:2
2025-12-12T11:57:40.520110Z :INFO: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.520109Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:40.520121Z :NOTICE: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:40.520126Z :DEBUG: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] [] Abort session to cluster
2025-12-12T11:57:40.520153Z :DEBUG: [local] 0x000073AEFFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_SessionAbort/test-topic" } consumer: "TxUsageTable-DirectRead_SessionAbort-test-consumer" }
2025-12-12T11:57:40.520265Z :DEBUG: [local] 0x000073AEFF743910 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 Close
2025-12-12T11:57:40.520308Z :DEBUG: [local] 0x000073AEFF743910 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_SessionAbort-test-consumer_1_5_1543043980475502612_v1 Close
2025-12-12T11:57:40.520325Z :NOTICE: [local] [local] [2e1b00de-963ac40c-99dd6777-5486b0e8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
