2025-12-12T12:00:25.052466Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T12:00:25.052606Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:25.052797Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T12:00:25.052833Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T12:00:25.052929Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:25.058740Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.058761Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540825058 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:25.058790Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0"
2025-12-12T12:00:25.058796Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:25.058856Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:25.058890Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:25.060203Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:25.060218Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:25.060223Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:25.060485Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:25.060569Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:25.060592Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T12:00:25.060673Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:25.067217Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.067268Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|876abc8c-f29d17e2-ff429aa9-c010b540_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0"
2025-12-12T12:00:25.067273Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:25.067341Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1ywfc95gtxtebdpepkd}, WriteCount=1, AckCount=0
2025-12-12T12:00:25.067355Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:25.067374Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:25.067379Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:25.067540Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T12:00:25.067709Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:25.067938Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T12:00:25.067966Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T12:00:25.068056Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:25.070977Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.071041Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_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: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:25.071054Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1ywfc95gtxtebdpepkd}, WriteCount=1, AckCount=1
2025-12-12T12:00:25.071059Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:25.074215Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.074240Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540825074 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:25.074273Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0"
2025-12-12T12:00:25.074279Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:25.074344Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:25.074418Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:25.077158Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:25.077187Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:25.077195Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:25.077577Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:25.077904Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:25.077940Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T12:00:25.078066Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:25.084753Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.084800Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f6a532f9-c95db177-27716106-9dbfac03_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0"
2025-12-12T12:00:25.084806Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:25.084874Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1ywfc95gtxtebdpepkd}, WriteCount=1, AckCount=0
2025-12-12T12:00:25.084889Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:25.084906Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:25.084911Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:25.085839Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1zxffcmvcwcc6d9syks}, WriteCount=1, AckCount=0
2025-12-12T12:00:25.085848Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:25.085858Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:25.085871Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:25.085934Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1zxffcmvcwcc6d9syks}, WriteCount=1, AckCount=0
2025-12-12T12:00:25.085937Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:25.085941Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:25.085943Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:25.086007Z :INFO: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Starting read session
2025-12-12T12:00:25.086012Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Starting single session
2025-12-12T12:00:25.086284Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:25.086303Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:25.086308Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:25.086729Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Successfully connected. Initializing session
2025-12-12T12:00:25.087516Z :INFO: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1
2025-12-12T12:00:25.087532Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:25.087604Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:25.088545Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.088596Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_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-12T12:00:25.088605Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1ywfc95gtxtebdpepkd}, WriteCount=1, AckCount=1
2025-12-12T12:00:25.088609Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:25.088955Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.088992Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_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-12T12:00:25.089004Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1zxffcmvcwcc6d9syks}, WriteCount=1, AckCount=1
2025-12-12T12:00:25.089002Z :INFO: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:25.089008Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:25.089122Z :DEBUG: [local] 0x00003069FF740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:25.089141Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:25.089317Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:25.089321Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:25.089323Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:25.089421Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:25.089451Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer" }
2025-12-12T12:00:25.090281Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:25.090291Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:25.090294Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:25.090304Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:25.090312Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:25.090673Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:25.090691Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:25.099109Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:25.099161Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_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-12T12:00:25.099170Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=ZjcwZGVlNjItYWFlOGQyMmQtOTMwN2Q2ZGMtOWUxZDY0NDI=, 01kc96y1zxffcmvcwcc6d9syks}, WriteCount=1, AckCount=1
2025-12-12T12:00:25.099175Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:26.086344Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_A:0:1:0:0
2025-12-12T12:00:26.086374Z :INFO: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:27.089459Z :INFO: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Starting read session
2025-12-12T12:00:27.089476Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Starting single session
2025-12-12T12:00:27.089830Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:27.089838Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:27.089843Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:27.090231Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Successfully connected. Initializing session
2025-12-12T12:00:27.091260Z :INFO: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1
2025-12-12T12:00:27.091278Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:27.091318Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:27.092738Z :INFO: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:27.092902Z :DEBUG: [local] 0x00003069FF741210 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:27.092924Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:27.093182Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:27.093191Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:27.093194Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:27.093224Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:27.093277Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_B" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer" }
2025-12-12T12:00:27.093856Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:27.093865Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:27.093868Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:27.093881Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:27.093885Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:27.094180Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:27.094187Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:28.090307Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_B:0:1:0:0
2025-12-12T12:00:28.090336Z :INFO: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:29.100102Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T12:00:29.100133Z :DEBUG: [local] 0x00003069FFBC7EA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:29.100153Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T12:00:29.100169Z :DEBUG: [local] 0x00003069FFBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:29.100230Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:29.100256Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:29.100268Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:29.100284Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:29.100304Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T12:00:29.100334Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Returning serverBytesSize = 164 to budget
2025-12-12T12:00:29.100335Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T12:00:29.100341Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T12:00:29.100373Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Returning serverBytesSize = 164 to budget
2025-12-12T12:00:29.100384Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T12:00:29.100437Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:29.100450Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:29.114933Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:29.114952Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T12:00:29.114961Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T12:00:29.114979Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:00:29.116152Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T12:00:31.114993Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:31.115016Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T12:00:31.115026Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T12:00:31.115044Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:00:31.116830Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T12:00:33.115080Z :INFO: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:33.115104Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_B:0:1:0:1
2025-12-12T12:00:33.115114Z :INFO: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6025 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:33.115134Z :NOTICE: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:33.115142Z :DEBUG: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] [] Abort session to cluster
2025-12-12T12:00:33.115522Z :DEBUG: [local] 0x00003069FF741210 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 Close
2025-12-12T12:00:33.115614Z :DEBUG: [local] 0x00003069FF741210 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_7863993772150908223_v1 Close
2025-12-12T12:00:33.115632Z :NOTICE: [local] [local] [5aea7dc7-1bb0d046-6962d7d3-bda512d9] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:33.115904Z :INFO: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:33.115914Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_4/topic_A:0:1:0:1
2025-12-12T12:00:33.115920Z :INFO: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8029 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:33.115930Z :NOTICE: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:33.115935Z :DEBUG: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] [] Abort session to cluster
2025-12-12T12:00:33.115959Z :DEBUG: [local] 0x00003069FF740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 Close
2025-12-12T12:00:33.115978Z :DEBUG: [local] 0x00003069FF740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_6631469526589043926_v1 Close
2025-12-12T12:00:33.115986Z :NOTICE: [local] [local] [8d442f19-9ea29cf4-462a2081-ce8442e1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:33.116198Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:33.116204Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:33.116210Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:33.116234Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:33.116238Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2ff40901-f79a99e1-8ad4e9cb-a7bd4615_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:00:33.116490Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:33.116495Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:33.116499Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:33.116584Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:33.116589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d7269c73-ab5586d8-bda7e1b4-d168f14_0]  PartitionId [0]  Generation [1] Write session: destroy
