2025-12-12T11:57:40.560921Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:40.561087Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:40.565666Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:40.565709Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:40.565820Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.571948Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.571973Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540660571 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.572002Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0"
2025-12-12T11:57:40.572009Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.572051Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:40.572089Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:40.573289Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_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.573302Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:40.573308Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:40.573513Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.573723Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:40.573741Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:40.573822Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.574570Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.574585Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|79d5fd1e-dec3d04b-647292fc-b41f98dc_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0"
2025-12-12T11:57:40.574588Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.574634Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:40.574667Z :INFO: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:40.574854Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.574862Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:40.576221Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.576248Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_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.576252Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:40.576255Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:40.674755Z :INFO: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:40.674779Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:40.675075Z :INFO: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:40.675087Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.675101Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:40.675122Z :DEBUG: [local]  TraceId []  SessionId [e3071000-e1839956-5ce78be1-8e0a038b|a2f229b9-e8cf955c-20545752-2693d82f_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:40.677652Z :INFO: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] Starting read session
2025-12-12T11:57:40.677665Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] Starting single session
2025-12-12T11:57:40.677859Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.677864Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.677869Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:40.678031Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Successfully connected. Initializing session
2025-12-12T11:57:40.678918Z :INFO: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1
2025-12-12T11:57:40.678944Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.679033Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.680226Z :INFO: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:40.680307Z :DEBUG: [local] 0x000073AEFF744610 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:40.680324Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:40.680443Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:40.680491Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic" } consumer: "TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer" }
2025-12-12T11:57:40.680979Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:40.680989Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:40.681092Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:40.681099Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.681121Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.681128Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.681476Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_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.681486Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:40.681525Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:40.681529Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:40.681617Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.681642Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.681696Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:40.681707Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:40.681711Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.681808Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.681854Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:40.681866Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:40.681872Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:40.681894Z :INFO: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:40.681900Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic:0:1:0:0
2025-12-12T11:57:40.681907Z :INFO: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.681923Z :NOTICE: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:40.681930Z :DEBUG: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] [] Abort session to cluster
2025-12-12T11:57:40.682041Z :DEBUG: [local] 0x000073AEFF744610 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 Close
2025-12-12T11:57:40.682054Z :DEBUG: [local] 0x000073AEFF744610 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_7_1209506160118784868_v1 Close
2025-12-12T11:57:40.682061Z :NOTICE: [local] [local] [4a5f69ab-f0b06cc-100c76a8-eefaf92f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:40.684111Z :INFO: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] Starting read session
2025-12-12T11:57:40.684117Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] Starting single session
2025-12-12T11:57:40.684331Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.684336Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.684339Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:40.684475Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Successfully connected. Initializing session
2025-12-12T11:57:40.685094Z :INFO: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1
2025-12-12T11:57:40.685104Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.685156Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.686331Z :INFO: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:40.686400Z :DEBUG: [local] 0x000073AEFF746D10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:40.686411Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:40.686513Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:40.686517Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.686519Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:40.686542Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:40.686570Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic" } consumer: "TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer" }
2025-12-12T11:57:40.686987Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:40.686995Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:40.686998Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.687005Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.687009Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.687257Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_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.687264Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:40.687320Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:40.687324Z :DEBUG: [local] 0x000073AEFFBC5DA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:40.687399Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Got ReadResponse, serverBytesSize = 162, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.687413Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.687458Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:40.687475Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Returning serverBytesSize = 162 to budget
2025-12-12T11:57:40.687480Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] In ContinueReadingDataImpl, ReadSizeBudget = 162, ReadSizeServerDelta = 52428638
2025-12-12T11:57:40.687554Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.687583Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:40.687593Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:40.687598Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:40.687613Z :INFO: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:40.687618Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_TwoSessionOneConsumer/test-topic:0:1:0:0
2025-12-12T11:57:40.687622Z :INFO: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.687633Z :NOTICE: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:40.687636Z :DEBUG: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] [] Abort session to cluster
2025-12-12T11:57:40.687725Z :DEBUG: [local] 0x000073AEFF746D10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 Close
2025-12-12T11:57:40.687739Z :DEBUG: [local] 0x000073AEFF746D10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_TwoSessionOneConsumer-test-consumer_1_9_3370852582476964764_v1 Close
2025-12-12T11:57:40.687746Z :NOTICE: [local] [local] [690acbd2-c47dafe2-3015a310-c0081a97] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
