2025-12-12T11:55:22.127261Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:55:22.127466Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:22.127717Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:55:22.127760Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_10/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:55:22.127895Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:22.134945Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:22.134969Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540522134 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:22.135002Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0"
2025-12-12T11:55:22.135008Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:22.135105Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:22.135242Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:22.136718Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_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:22.136736Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:22.136742Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:22.137013Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:22.137210Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:22.137254Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_10/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:55:22.137407Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:22.144237Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:22.144286Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2e72ab53-16de7d94-b03176ac-4d62828_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0"
2025-12-12T11:55:22.144293Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:22.144362Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=NjlkZjZjYzktZmE1NTVhZDEtZjc4MzIzZTctODg0YjMzMTY=, 01kc96mt4e1q15btnm0g16ezsd}, WriteCount=1, AckCount=0
2025-12-12T11:55:22.144380Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:22.144401Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:22.144408Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:22.148080Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:22.148131Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_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:22.148140Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=NjlkZjZjYzktZmE1NTVhZDEtZjc4MzIzZTctODg0YjMzMTY=, 01kc96mt4e1q15btnm0g16ezsd}, WriteCount=1, AckCount=1
2025-12-12T11:55:22.148401Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:22.150969Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=NjlkZjZjYzktZmE1NTVhZDEtZjc4MzIzZTctODg0YjMzMTY=, 01kc96mt564ejzq9j9btash63x}, WriteCount=1, AckCount=0
2025-12-12T11:55:22.150983Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:22.151001Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:22.151005Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:22.154143Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:22.154201Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_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 { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:22.223525Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=NjlkZjZjYzktZmE1NTVhZDEtZjc4MzIzZTctODg0YjMzMTY=, 01kc96mt564ejzq9j9btash63x}, WriteCount=1, AckCount=1
2025-12-12T11:55:22.223901Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:22.226217Z :INFO: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Starting read session
2025-12-12T11:55:22.226231Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Starting single session
2025-12-12T11:55:22.226503Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:22.226510Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:22.226515Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:22.226812Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Successfully connected. Initializing session
2025-12-12T11:55:22.227845Z :INFO: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1
2025-12-12T11:55:22.227867Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:22.227936Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:22.228914Z :INFO: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_10/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:22.228992Z :DEBUG: [local] 0x00001393BF746D10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:22.229005Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:22.229133Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:22.229137Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:22.229139Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:22.229176Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:22.229235Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_10/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer" }
2025-12-12T11:55:22.229753Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:22.229760Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:22.229762Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:22.229773Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:22.229777Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:22.230071Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_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:22.230083Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:22.230130Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:55:22.230134Z :DEBUG: [local] 0x00001393BFBC94A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:22.230237Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Got ReadResponse, serverBytesSize = 306, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:55:22.230259Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:55:22.230298Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:55:22.230313Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Returning serverBytesSize = 306 to budget
2025-12-12T11:55:22.230317Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 306, ReadSizeServerDelta = 52428494
2025-12-12T11:55:22.230347Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:22.230395Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:22.230408Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:55:22.230431Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:55:22.230439Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:55:22.230460Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:55:22.231899Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:55:23.227357Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_10/topic_A:0:1:1:2
2025-12-12T11:55:23.227385Z :INFO: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:24.226281Z :INFO: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:24.226308Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_10/topic_A:0:1:1:2
2025-12-12T11:55:24.226320Z :INFO: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:24.226342Z :NOTICE: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:24.226351Z :DEBUG: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] [] Abort session to cluster
2025-12-12T11:55:24.226569Z :DEBUG: [local] 0x00001393BF746D10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 Close
2025-12-12T11:55:24.226599Z :DEBUG: [local] 0x00001393BF746D10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_10-test-consumer_1_9_4084729706009602432_v1 Close
2025-12-12T11:55:24.226614Z :NOTICE: [local] [local] [12ca87d0-1e4b1b07-2ce29b02-86fa13f0] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:24.226786Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:24.226797Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:24.226803Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:24.226960Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:24.226970Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:24.226980Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:55:24.226995Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8b4eac0-f55c9529-f3a28ce1-3a65535_0]  PartitionId [0]  Generation [1] Write session: destroy
