2025-12-12T11:57:57.498664Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:57.498853Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:57.499077Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:57.499112Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_8/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:57.499216Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:57.505847Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:57.505869Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540677505 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:57.505895Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0"
2025-12-12T11:57:57.505900Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:57.505973Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:57.506016Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:57.507450Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_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:57.507466Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:57.507472Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:57.507830Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:57.507983Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:57.508011Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_8/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:57.508112Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:57.515257Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:57.515305Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6935b14d-bfcd53af-4fad5429-cf2358c0_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0"
2025-12-12T11:57:57.515312Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:57.515408Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=OTQzNDA4YjgtZWY4ZDkwOGQtNWY0MmRhY2EtNWI3Y2YwOWM=, 01kc96shvt2yb328htp8dxhy9r}, WriteCount=1, AckCount=0
2025-12-12T11:57:57.515434Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:57.515460Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:57.515467Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:57.515624Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:57.515631Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:57.515634Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:57.515675Z :INFO: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Starting read session
2025-12-12T11:57:57.515680Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Starting single session
2025-12-12T11:57:57.516005Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:57.516010Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:57.516014Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:57.516271Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Successfully connected. Initializing session
2025-12-12T11:57:57.517198Z :INFO: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1
2025-12-12T11:57:57.517217Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:57.517286Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:57.519736Z :INFO: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_8/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:57.519876Z :DEBUG: [local] 0x000073AEFF741F10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:57.519903Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:57.520131Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:57.520137Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:57.520140Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:57.520271Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:57.520324Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_8/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer" }
2025-12-12T11:57:57.520913Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:57.520927Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:57.520931Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:57.520943Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:57.520949Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:57.521167Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:57.521198Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:57.521209Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=OTQzNDA4YjgtZWY4ZDkwOGQtNWY0MmRhY2EtNWI3Y2YwOWM=, 01kc96shvt2yb328htp8dxhy9r}, WriteCount=1, AckCount=1
2025-12-12T11:57:57.521215Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:57.521294Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_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:57.521305Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:57.521378Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:57.521399Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:57.521399Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { } } write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:57.521406Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:57.521408Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:57.521412Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:57.521524Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:57.521585Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:57.521626Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:57.521648Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:57:57.521654Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:57:57.521719Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:57.521775Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:57.521796Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:57.521809Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:57.521831Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:57:57.523062Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:57:58.516357Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_8/topic_A:0:1:0:1
2025-12-12T11:57:58.516385Z :INFO: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:59.519094Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=OTQzNDA4YjgtZWY4ZDkwOGQtNWY0MmRhY2EtNWI3Y2YwOWM=, 01kc96skty3a1ajt16v1555mn2}, WriteCount=1, AckCount=0
2025-12-12T11:57:59.519117Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:59.519137Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:59.519142Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:59.522880Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:59.522932Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:59.522951Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=OTQzNDA4YjgtZWY4ZDkwOGQtNWY0MmRhY2EtNWI3Y2YwOWM=, 01kc96skty3a1ajt16v1555mn2}, WriteCount=1, AckCount=1
2025-12-12T11:57:59.523198Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:59.525167Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 1
2025-12-12T11:57:59.525177Z :DEBUG: [local] 0x000073AEFFBC8420 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:59.525290Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:59.525323Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:57:59.525414Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T11:57:59.525450Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:57:59.525459Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:57:59.525637Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:59.525701Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:59.525721Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:59.525732Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:57:59.525758Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Commit offsets [1, 2). Partition stream id: 1
2025-12-12T11:57:59.526839Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:58:01.525187Z :INFO: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Closing read session. Close timeout: 0.000000s
2025-12-12T11:58:01.525215Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_8/topic_A:0:1:1:2
2025-12-12T11:58:01.525226Z :INFO: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4009 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:58:01.525248Z :NOTICE: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:58:01.525258Z :DEBUG: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] [] Abort session to cluster
2025-12-12T11:58:01.525494Z :DEBUG: [local] 0x000073AEFF741F10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 Close
2025-12-12T11:58:01.525530Z :DEBUG: [local] 0x000073AEFF741F10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_8-test-consumer_1_21_8159630171884567214_v1 Close
2025-12-12T11:58:01.525549Z :NOTICE: [local] [local] [120a1793-789235d1-10f0f358-62b7ae39] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:58:01.525775Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:58:01.525788Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:58:01.525794Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:58:01.525947Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:58:01.525954Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4b6fe69c-f9e55e73-7e236b29-5449279f_0]  PartitionId [0]  Generation [1] Write session: destroy
