2025-12-12T11:57:29.825089Z :INFO: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] Starting read session
2025-12-12T11:57:29.825107Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] Starting single session
2025-12-12T11:57:29.825356Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:29.825361Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:29.825366Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:29.830315Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Successfully connected. Initializing session
2025-12-12T11:57:29.831890Z :INFO: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1
2025-12-12T11:57:29.831919Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:29.832020Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:29.833888Z :INFO: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:29.833958Z :DEBUG: [local] 0x0000514CBF748710 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:29.833975Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:29.834093Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:29.834098Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:29.834101Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:29.834166Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:29.834173Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:29.834214Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" } consumer: "TxUsageQuery-DirectRead_SessionAbort-test-consumer" }
2025-12-12T11:57:29.834454Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:29.835018Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:29.835049Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:29.835054Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:29.835064Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:29.835070Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:29.835594Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_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:29.835599Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:29.835607Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:29.835626Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:29.835720Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:29.841957Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:29.841981Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540649841 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:29.842009Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0"
2025-12-12T11:57:29.842013Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:29.842074Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:29.842134Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:29.843819Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_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:29.843839Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:29.843846Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:29.844162Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:29.844451Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:29.844491Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:29.844606Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:29.845880Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:29.845910Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|641c4145-1c13a91e-73775642-e6195946_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0"
2025-12-12T11:57:29.845918Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:29.845979Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:29.846014Z :INFO: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:29.846196Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:29.846208Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:29.848208Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:29.848290Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_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:29.848302Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:29.848311Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:29.848676Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:29.848693Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:29.848895Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:29.848923Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:29.849015Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:29.849036Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:29.849042Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:29.849107Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:29.946108Z :INFO: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:29.946129Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:29.946352Z :INFO: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:29.946362Z :DEBUG: [local]  TraceId []  SessionId [9261e918-98964aae-3eb1aadc-92e861b2|c982dea-3716f34-5eb3a925-6143826_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:29.946543Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:29.946555Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:29.946565Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:29.946633Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:29.946843Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:29.947578Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:29.947620Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:29.947710Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:29.955294Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:29.955321Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540649955 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:29.955351Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0"
2025-12-12T11:57:29.955357Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:29.955442Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:29.955488Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:29.956716Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_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:29.956733Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:29.956737Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:29.957051Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:29.957204Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:29.957230Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:29.957352Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:29.958539Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:29.958559Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f411910e-bf0da550-ca2ced53-263970d2_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0"
2025-12-12T11:57:29.958565Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:29.958633Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:29.958673Z :INFO: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:29.958799Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:29.958813Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:29.960468Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:29.960508Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_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:29.960513Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:29.960516Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:29.960769Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 1
2025-12-12T11:57:29.960780Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:29.960889Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:29.960906Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:29.961043Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T11:57:29.961059Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:29.961064Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:29.961177Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.058738Z :INFO: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:30.058770Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:30.059256Z :INFO: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:30.059278Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:30.059301Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:30.059402Z :DEBUG: [local]  TraceId []  SessionId [7806595c-4a0063a0-525754-7a929d26|35e5e781-ff232019-4c9afa86-c9d3c791_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:30.059692Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:30.059709Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:30.059718Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:30.059759Z :INFO: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:30.059769Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic:0:1:1:0
2025-12-12T11:57:30.059778Z :INFO: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] Counters: { Errors: 0 CurrentSessionLifetimeMs: 234 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.059795Z :NOTICE: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:30.059801Z :DEBUG: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] [] Abort session to cluster
2025-12-12T11:57:30.059947Z :DEBUG: [local] 0x0000514CBF748710 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 Close
2025-12-12T11:57:30.059978Z :DEBUG: [local] 0x0000514CBF748710 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_1_3578890713894472431_v1 Close
2025-12-12T11:57:30.059992Z :NOTICE: [local] [local] [5db75326-e79c51ce-338d17a7-c49e7a57] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:30.061637Z :INFO: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] Starting read session
2025-12-12T11:57:30.061656Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] Starting single session
2025-12-12T11:57:30.061832Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.061836Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.061840Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:30.062071Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Successfully connected. Initializing session
2025-12-12T11:57:30.063138Z :INFO: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1
2025-12-12T11:57:30.063159Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.063215Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.065040Z :INFO: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:30.065158Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:30.065180Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:30.065357Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:30.065363Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.065366Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:30.065391Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:30.065451Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" } consumer: "TxUsageQuery-DirectRead_SessionAbort-test-consumer" }
2025-12-12T11:57:30.066075Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:30.066082Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:30.066093Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.066105Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.066111Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.066571Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_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:30.066588Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:30.066653Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:30.066659Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:30.066784Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Got ReadResponse, serverBytesSize = 302, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428498
2025-12-12T11:57:30.066812Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428498
2025-12-12T11:57:30.066937Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:30.066959Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Returning serverBytesSize = 302 to budget
2025-12-12T11:57:30.066964Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] In ContinueReadingDataImpl, ReadSizeBudget = 302, ReadSizeServerDelta = 52428498
2025-12-12T11:57:30.067128Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.067180Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:30.067195Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:30.067208Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:30.067218Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:30.071454Z :INFO: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:30.071490Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic:0:1:1:0
2025-12-12T11:57:30.071503Z :INFO: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 9 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.071529Z :NOTICE: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:30.071541Z :DEBUG: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] [] Abort session to cluster
2025-12-12T11:57:30.071720Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 Close
2025-12-12T11:57:30.071753Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_3_3507524435512574192_v1 Close
2025-12-12T11:57:30.071769Z :NOTICE: [local] [local] [5d27d864-fc95f70c-53778403-a7c171b6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:30.071991Z :INFO: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] Starting read session
2025-12-12T11:57:30.071997Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] Starting single session
2025-12-12T11:57:30.072233Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.072241Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.072246Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:30.072556Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] Successfully connected. Initializing session
2025-12-12T11:57:30.073392Z :INFO: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1
2025-12-12T11:57:30.073410Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.073461Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.075002Z :INFO: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:30.075113Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:30.075135Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:30.075341Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:30.075351Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.075355Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:30.075365Z :INFO: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:30.075375Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic:0:1:0:2
2025-12-12T11:57:30.075378Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:30.075382Z :INFO: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.075418Z :NOTICE: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:30.075426Z :DEBUG: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] [] Abort session to cluster
2025-12-12T11:57:30.075440Z :DEBUG: [local] 0x0000514CBF607920 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_SessionAbort/test-topic" } consumer: "TxUsageQuery-DirectRead_SessionAbort-test-consumer" }
2025-12-12T11:57:30.075524Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 Close
2025-12-12T11:57:30.075553Z :DEBUG: [local] 0x0000514CBF742C10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_SessionAbort-test-consumer_1_5_13020621451351420491_v1 Close
2025-12-12T11:57:30.075564Z :NOTICE: [local] [local] [c02b833c-6b8a4c36-20b49483-10b60fde] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
