2025-12-12T11:55:29.151214Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:55:29.151379Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:29.155861Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:55:29.155923Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:55:29.156035Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:29.162637Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:29.162659Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540529162 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:29.162689Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0"
2025-12-12T11:55:29.162694Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:29.162719Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:29.162773Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:29.164160Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:29.164185Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:29.164192Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:29.164452Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:29.164567Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:29.164592Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:55:29.164702Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:29.170921Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:29.170955Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8007ff46-34b78d2a-178e3e87-3c63affe_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0"
2025-12-12T11:55:29.170965Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:29.171035Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:29.171060Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:29.171066Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:29.171180Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:29.171187Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:29.171190Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:29.171195Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:55:29.171199Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:29.171201Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:55:29.172702Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:29.172746Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:29.172753Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:55:29.172757Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:29.173585Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:29.173609Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 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:55:29.173616Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:55:29.173619Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:29.173930Z :INFO: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Starting read session
2025-12-12T11:55:29.252619Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Starting single session
2025-12-12T11:55:29.252752Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:29.252805Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written { offset: 2 } } 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:55:29.252811Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T11:55:29.252815Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:55:29.252816Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:29.252821Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:29.252824Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:29.253100Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Successfully connected. Initializing session
2025-12-12T11:55:29.254161Z :INFO: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1
2025-12-12T11:55:29.254179Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:29.254249Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:29.255640Z :INFO: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:29.255741Z :DEBUG: [local] 0x00001393BF74AE10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:29.255760Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:29.255948Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:29.255954Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:29.255957Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:29.256001Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:29.256043Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer" }
2025-12-12T11:55:29.256597Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:29.256623Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:29.256627Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:29.256640Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:29.256647Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:29.257018Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:29.257031Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:29.257182Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 2
2025-12-12T11:55:29.257189Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:29.257307Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Got ReadResponse, serverBytesSize = 457, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:55:29.257335Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:55:29.257384Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-2)
2025-12-12T11:55:29.257412Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Returning serverBytesSize = 457 to budget
2025-12-12T11:55:29.257417Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] In ContinueReadingDataImpl, ReadSizeBudget = 457, ReadSizeServerDelta = 52428343
2025-12-12T11:55:29.257575Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:29.257635Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:29.257647Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:55:29.257653Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:55:29.257664Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:55:29.257673Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:55:30.253357Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_A:0:1:2:0
2025-12-12T11:55:30.253385Z :INFO: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1079 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:31.174051Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:55:31.174290Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:31.174616Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:55:31.174661Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:55:31.174837Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:31.182209Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:31.182233Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540531182 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:31.182266Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0"
2025-12-12T11:55:31.182272Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:31.182305Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:31.182356Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:31.183734Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:31.183752Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:31.183758Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:31.184009Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:31.184133Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:31.184161Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:55:31.184292Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:31.190235Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:31.190300Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e7a27c28-dc83522e-41e81cc4-82ceb217_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|33249367-28c6e129-4af44581-9f407951_0"
2025-12-12T11:55:31.190307Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:31.190379Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTAzM2YxYzQtNTQ4ZjgwOGEtYzFkYmY1MGMtYjY5ZTdjODg=, 01kc96n10n0g8zhxcrm1tmq355}, WriteCount=1, AckCount=0
2025-12-12T11:55:31.190397Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:31.190421Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:31.190428Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:31.190577Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YTAzM2YxYzQtNTQ4ZjgwOGEtYzFkYmY1MGMtYjY5ZTdjODg=, 01kc96n10n0g8zhxcrm1tmq355}, WriteCount=2, AckCount=0
2025-12-12T11:55:31.190585Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:31.190593Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:31.190596Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:31.190604Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=YTAzM2YxYzQtNTQ4ZjgwOGEtYzFkYmY1MGMtYjY5ZTdjODg=, 01kc96n10n0g8zhxcrm1tmq355}, WriteCount=3, AckCount=0
2025-12-12T11:55:31.190611Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:55:31.190616Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:31.190619Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:55:31.194596Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:31.194664Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 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:55:31.194678Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTAzM2YxYzQtNTQ4ZjgwOGEtYzFkYmY1MGMtYjY5ZTdjODg=, 01kc96n10n0g8zhxcrm1tmq355}, WriteCount=3, AckCount=1
2025-12-12T11:55:31.262471Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:31.262669Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:31.262722Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:31.262735Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YTAzM2YxYzQtNTQ4ZjgwOGEtYzFkYmY1MGMtYjY5ZTdjODg=, 01kc96n10n0g8zhxcrm1tmq355}, WriteCount=3, AckCount=2
2025-12-12T11:55:31.262738Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:31.262775Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:31.262788Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:31.262793Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=YTAzM2YxYzQtNTQ4ZjgwOGEtYzFkYmY1MGMtYjY5ZTdjODg=, 01kc96n10n0g8zhxcrm1tmq355}, WriteCount=3, AckCount=3
2025-12-12T11:55:31.263142Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:55:31.271697Z :INFO: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Starting read session
2025-12-12T11:55:31.271717Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Starting single session
2025-12-12T11:55:31.271998Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:31.272005Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:31.272011Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:31.272367Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Successfully connected. Initializing session
2025-12-12T11:55:31.273470Z :INFO: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1
2025-12-12T11:55:31.273491Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:31.273590Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:31.275032Z :INFO: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:31.275129Z :DEBUG: [local] 0x00001393BF746010 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:31.275149Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:31.275338Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:31.275346Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:31.275349Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:31.275382Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:31.275428Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_B" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer" }
2025-12-12T11:55:31.275981Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:31.276004Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:31.276007Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:31.276022Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:31.276029Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:31.276422Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:31.276433Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:31.276544Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 2
2025-12-12T11:55:31.276553Z :DEBUG: [local] 0x00001393BFBCC620 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:31.276646Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Got ReadResponse, serverBytesSize = 457, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:55:31.276672Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:55:31.276708Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-2)
2025-12-12T11:55:31.276731Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Returning serverBytesSize = 457 to budget
2025-12-12T11:55:31.276737Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] In ContinueReadingDataImpl, ReadSizeBudget = 457, ReadSizeServerDelta = 52428343
2025-12-12T11:55:31.276847Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:31.276899Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:31.276914Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:55:31.276919Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:55:31.276931Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:55:31.276939Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:55:31.276973Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Commit offsets [0, 3). Partition stream id: 1
2025-12-12T11:55:31.278147Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 3 } }
2025-12-12T11:55:32.272355Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_B:0:1:2:3
2025-12-12T11:55:32.272395Z :INFO: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:33.271756Z :INFO: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:33.271794Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_B:0:1:2:3
2025-12-12T11:55:33.271807Z :INFO: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:33.271829Z :NOTICE: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:33.271837Z :DEBUG: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] [] Abort session to cluster
2025-12-12T11:55:33.272023Z :DEBUG: [local] 0x00001393BF746010 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 Close
2025-12-12T11:55:33.272087Z :DEBUG: [local] 0x00001393BF746010 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_14183134200430340447_v1 Close
2025-12-12T11:55:33.272101Z :NOTICE: [local] [local] [78e8bf1-2f4be6fd-cb05702e-35992bbc] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:33.272231Z :INFO: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:33.272240Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_25/topic_A:0:1:2:0
2025-12-12T11:55:33.272274Z :INFO: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4098 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:33.272281Z :NOTICE: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:33.272285Z :DEBUG: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] [] Abort session to cluster
2025-12-12T11:55:33.272337Z :DEBUG: [local] 0x00001393BF74AE10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 Close
2025-12-12T11:55:33.272355Z :DEBUG: [local] 0x00001393BF74AE10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_17525579403882204478_v1 Close
2025-12-12T11:55:33.272364Z :NOTICE: [local] [local] [c432cdd4-7b8eb112-4c463d28-c0ffa676] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:33.272629Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:33.272642Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:33.272649Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:33.272817Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:33.272824Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|33249367-28c6e129-4af44581-9f407951_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:33.273094Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:33.273112Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:33.273116Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:33.273170Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:33.273172Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a6a59c84-70c0b6df-5b2205ea-182828cb_0]  PartitionId [0]  Generation [1] Write session: destroy
