2025-12-12T11:58:00.760276Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T11:58:00.760460Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:58:00.760493Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:58:00.762022Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:58:00.762039Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:58:00.762047Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:58:00.762315Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:58:00.762360Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_28/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:58:00.762468Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:58:00.769521Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:58:00.769543Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540680769 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:58:00.769576Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0"
2025-12-12T11:58:00.769651Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=NzRlYTE3ZWEtYzc5MzE3ZGQtOTUzODkzY2UtMmQ4MWUyMzE=, 01kc96sn1qcjxngma4vz9evsfn}, WriteCount=1, AckCount=0
2025-12-12T11:58:00.769677Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:58:00.769701Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:58:00.769708Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:58:00.779534Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:58:00.779600Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_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 { nanos: 6000000 } max_queue_wait_time { nanos: 6000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:58:00.779613Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=NzRlYTE3ZWEtYzc5MzE3ZGQtOTUzODkzY2UtMmQ4MWUyMzE=, 01kc96sn1qcjxngma4vz9evsfn}, WriteCount=1, AckCount=1
2025-12-12T11:58:00.779944Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:58:00.782211Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T11:58:00.782447Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:58:00.782476Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:58:00.783495Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:58:00.783508Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:58:00.783514Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:58:00.783679Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:58:00.783721Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_28/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:58:00.783821Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:58:00.789968Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:58:00.789993Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540680789 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:58:00.790023Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0"
2025-12-12T11:58:00.790128Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:58:00.790165Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:58:00.790172Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:58:00.790381Z :INFO: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Starting read session
2025-12-12T11:58:00.790389Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Starting single session
2025-12-12T11:58:00.790634Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:58:00.790640Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:58:00.790645Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:58:00.790892Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Successfully connected. Initializing session
2025-12-12T11:58:00.791680Z :INFO: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1
2025-12-12T11:58:00.791711Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:58:00.791784Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:58:00.792147Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:58:00.792211Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 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:58:00.792221Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:58:00.792226Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:58:00.792814Z :INFO: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_28/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:58:00.792867Z :DEBUG: [local] 0x000071673F741F10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:58:00.792887Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:58:00.793039Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:58:00.793046Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:58:00.793049Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:58:00.793070Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:58:00.793103Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_28/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer" }
2025-12-12T11:58:00.793692Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:58:00.793704Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 Got InitResponse 
2025-12-12T11:58:00.793707Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:58:00.793718Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:58:00.793724Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:58:00.794090Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:58:00.794097Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:58:00.794304Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:58:00.794321Z :DEBUG: [local] 0x000071673FBC9A20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:58:00.794389Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Got ReadResponse, serverBytesSize = 36310, now ReadSizeBudget = 0, ReadSizeServerDelta = 52392490
2025-12-12T11:58:00.794410Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52392490
2025-12-12T11:58:00.794444Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:58:00.794470Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Returning serverBytesSize = 36310 to budget
2025-12-12T11:58:00.794475Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] In ContinueReadingDataImpl, ReadSizeBudget = 36310, ReadSizeServerDelta = 52392490
2025-12-12T11:58:00.794585Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:58:00.794647Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:58:00.794670Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:58:00.794683Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] The application data is transferred to the client. Number of messages 2, size 36000 bytes
2025-12-12T11:58:00.794691Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:58:00.794716Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:58:00.795843Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:58:01.791359Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_28/topic_A:0:1:1:2
2025-12-12T11:58:01.791393Z :INFO: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 36000 MessagesRead: 2 BytesReadCompressed: 36000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:58:02.790474Z :INFO: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Closing read session. Close timeout: 0.000000s
2025-12-12T11:58:02.790505Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_28/topic_A:0:1:1:2
2025-12-12T11:58:02.790525Z :INFO: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 36000 MessagesRead: 2 BytesReadCompressed: 36000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:58:02.790545Z :NOTICE: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:58:02.790554Z :DEBUG: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] [] Abort session to cluster
2025-12-12T11:58:02.790744Z :DEBUG: [local] 0x000071673F741F10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 Close
2025-12-12T11:58:02.790882Z :DEBUG: [local] 0x000071673F741F10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_28-test-consumer_1_21_6614655149652192499_v1 Close
2025-12-12T11:58:02.790924Z :NOTICE: [local] [local] [a07c6796-82d44d29-b76580e1-406b5653] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:58:02.791113Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:58:02.791116Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:58:02.791120Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:58:02.791285Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:58:02.791290Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|ccb9c243-cd7f6261-35f82b6-76ea8092_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:58:02.791469Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:58:02.791473Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:58:02.791475Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:58:02.791612Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:58:02.791635Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:58:02.791649Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:58:02.791663Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|b8cad8d5-8ad19ad7-c4067f3e-6cc02682_0]  PartitionId [0]  Generation [1] Write session: destroy
