2025-12-12T11:57:30.120466Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:30.120683Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:30.125845Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:30.125899Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:30.126046Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:30.132410Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.132433Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540650132 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.132464Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0"
2025-12-12T11:57:30.132471Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:30.132510Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:30.132564Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:30.134306Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_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:30.134324Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:30.134328Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:30.134631Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:30.134755Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:30.134784Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:30.134904Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:30.135769Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.135786Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|740be6a-428d7589-3fa8e441-fd60d2c3_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0"
2025-12-12T11:57:30.135791Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:30.135844Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:30.135880Z :INFO: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:30.136055Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:30.136069Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:30.137564Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:30.137613Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_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:30.137619Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:30.137622Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:30.235941Z :INFO: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:30.235970Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:30.236233Z :INFO: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:30.236247Z :DEBUG: [local]  TraceId []  SessionId [9d652e37-3005a198-3a43e562-2d13d024|e8e48db2-d8bef19-b5105184-43483250_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:30.244347Z :INFO: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] Starting read session
2025-12-12T11:57:30.244381Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] Starting single session
2025-12-12T11:57:30.244624Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.244629Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.244634Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:30.244900Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Successfully connected. Initializing session
2025-12-12T11:57:30.245969Z :INFO: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1
2025-12-12T11:57:30.245998Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.246106Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.247902Z :INFO: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:30.248117Z :DEBUG: [local] 0x0000514CBF749410 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:30.248147Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:30.248466Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:30.248476Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.248480Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:30.248531Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:30.248604Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic" } consumer: "TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer" }
2025-12-12T11:57:30.249381Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:30.249395Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:30.249399Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.249412Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.249418Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.250022Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_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.250043Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:30.250120Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:30.250126Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:30.250260Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:30.250282Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:30.250354Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:30.250374Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:30.250380Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:30.250502Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.250586Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:30.250612Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:30.250628Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:30.250671Z :INFO: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:30.250681Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic:0:1:0:0
2025-12-12T11:57:30.250690Z :INFO: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.250726Z :NOTICE: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:30.250734Z :DEBUG: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] [] Abort session to cluster
2025-12-12T11:57:30.250900Z :DEBUG: [local] 0x0000514CBF749410 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 Close
2025-12-12T11:57:30.250973Z :DEBUG: [local] 0x0000514CBF749410 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_15448269315101151524_v1 Close
2025-12-12T11:57:30.250989Z :NOTICE: [local] [local] [82db543-30ad17b6-405e85cc-16d86e39] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:30.254617Z :INFO: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] Starting read session
2025-12-12T11:57:30.254634Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] Starting single session
2025-12-12T11:57:30.254929Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.254935Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.254941Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:30.255127Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Successfully connected. Initializing session
2025-12-12T11:57:30.256204Z :INFO: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1
2025-12-12T11:57:30.256246Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:30.256347Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.258114Z :INFO: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:30.258246Z :DEBUG: [local] 0x0000514CBF740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:30.258269Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:30.258450Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:30.258461Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.258464Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:30.258487Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:30.258555Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic" } consumer: "TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer" }
2025-12-12T11:57:30.259222Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:30.259236Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:30.259240Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:30.259251Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.259257Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:30.259663Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_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.259676Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:30.259761Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:30.259772Z :DEBUG: [local] 0x0000514CBF604220 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:30.259890Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:30.259922Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:30.260003Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:30.260051Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:30.260059Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:30.260251Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:30.260322Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:30.260343Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:30.260353Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:30.260385Z :INFO: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:30.260394Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_TwoSessionOneConsumer/test-topic:0:1:0:0
2025-12-12T11:57:30.260402Z :INFO: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:30.260422Z :NOTICE: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:30.260428Z :DEBUG: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] [] Abort session to cluster
2025-12-12T11:57:30.260574Z :DEBUG: [local] 0x0000514CBF740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 Close
2025-12-12T11:57:30.260603Z :DEBUG: [local] 0x0000514CBF740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_7558960957275478942_v1 Close
2025-12-12T11:57:30.260615Z :NOTICE: [local] [local] [adeaa8d1-22bc638-78e6217e-8feee6f4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
