2025-12-12T12:00:16.980705Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T12:00:16.980916Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:16.981238Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T12:00:16.982965Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T12:00:16.983131Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:17.548307Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.548330Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540817548 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:17.548364Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0"
2025-12-12T12:00:17.548370Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:17.548396Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:17.548452Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:17.549696Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_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:17.549708Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:17.549714Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:17.550012Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:17.550140Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:17.550170Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T12:00:17.550257Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:17.556196Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.556222Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|6d1ded2e-76cb22e9-135786e5-d687becb_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0"
2025-12-12T12:00:17.556228Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:17.556339Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xt2g0c9cjnst6ded6y7p}, WriteCount=1, AckCount=0
2025-12-12T12:00:17.556364Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:17.556409Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:17.556416Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:17.556682Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T12:00:17.556927Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:17.557230Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T12:00:17.557258Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T12:00:17.557371Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:17.559570Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.559696Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_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:17.559706Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xt2g0c9cjnst6ded6y7p}, WriteCount=1, AckCount=1
2025-12-12T12:00:17.559710Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:17.563265Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.563282Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540817563 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:17.563296Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0"
2025-12-12T12:00:17.563301Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:17.563370Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:17.563415Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:17.564646Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_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:17.564660Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:17.564665Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:17.564921Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:17.565001Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:17.565023Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T12:00:17.565123Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:17.570662Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.570696Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|80613429-607a1eb2-4d4e6782-54a83f15_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0"
2025-12-12T12:00:17.570703Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:17.570782Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xt2g0c9cjnst6ded6y7p}, WriteCount=1, AckCount=0
2025-12-12T12:00:17.570809Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:17.570839Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:17.570846Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:17.571877Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xtn32mpafwgwx2amsbm8}, WriteCount=1, AckCount=0
2025-12-12T12:00:17.571886Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:17.571896Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:17.571899Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:17.571969Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xtn32mpafwgwx2amsbm8}, WriteCount=1, AckCount=0
2025-12-12T12:00:17.571971Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:17.571977Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:17.571980Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:17.572053Z :INFO: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Starting read session
2025-12-12T12:00:17.572058Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Starting single session
2025-12-12T12:00:17.572312Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:17.572317Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:17.572320Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:17.572495Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Successfully connected. Initializing session
2025-12-12T12:00:17.573244Z :INFO: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1
2025-12-12T12:00:17.573261Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:17.573323Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:17.574089Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.574150Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_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:17.574163Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xt2g0c9cjnst6ded6y7p}, WriteCount=1, AckCount=1
2025-12-12T12:00:17.574167Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:17.574732Z :INFO: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:17.574841Z :DEBUG: [local] 0x0000302C3F746D10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:17.574860Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:17.575005Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:17.575011Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:17.575014Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:17.575056Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:17.575089Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer" }
2025-12-12T12:00:17.575721Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.575748Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:17.575754Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xtn32mpafwgwx2amsbm8}, WriteCount=1, AckCount=1
2025-12-12T12:00:17.575759Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:17.575865Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:17.575891Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:17.575895Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:17.575904Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:17.575910Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:17.576261Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_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:17.576268Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:17.583236Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:17.583279Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:17.583290Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=MTc1YWNlYWMtYzc2ZGQyMjctODczZmQ3MjItNDFlMTVjMTQ=, 01kc96xtn32mpafwgwx2amsbm8}, WriteCount=1, AckCount=1
2025-12-12T12:00:17.583294Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:18.572345Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_A:0:1:0:0
2025-12-12T12:00:18.572366Z :INFO: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:19.575160Z :INFO: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Starting read session
2025-12-12T12:00:19.575178Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Starting single session
2025-12-12T12:00:19.575424Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:19.575429Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:19.575434Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:19.575742Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Successfully connected. Initializing session
2025-12-12T12:00:19.576791Z :INFO: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1
2025-12-12T12:00:19.576807Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:19.576848Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:19.578301Z :INFO: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:19.578385Z :DEBUG: [local] 0x0000302C3F740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:19.578402Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:19.578551Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:19.578558Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:19.578561Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:19.578606Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:19.578652Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_B" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer" }
2025-12-12T12:00:19.579198Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:19.579207Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:19.579210Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:19.579220Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:19.579224Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:19.579509Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_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:19.579515Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:20.576302Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_B:0:1:0:0
2025-12-12T12:00:20.576322Z :INFO: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:21.585283Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T12:00:21.585299Z :DEBUG: [local] 0x0000302C3FBC5820 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:21.585298Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T12:00:21.585308Z :DEBUG: [local] 0x0000302C3FBC26A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:21.585358Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:21.585358Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:21.585378Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:21.585383Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T12:00:21.585418Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T12:00:21.585435Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T12:00:21.585445Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Returning serverBytesSize = 164 to budget
2025-12-12T12:00:21.585473Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Returning serverBytesSize = 164 to budget
2025-12-12T12:00:21.585485Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T12:00:21.585489Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T12:00:21.585498Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:21.585499Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:21.593996Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:21.594022Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T12:00:21.594032Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T12:00:21.594060Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:00:21.595344Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T12:00:23.594105Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:23.594129Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T12:00:23.594139Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T12:00:23.594161Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:00:23.595833Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T12:00:25.594198Z :INFO: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:25.594226Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_B:0:1:0:1
2025-12-12T12:00:25.594237Z :INFO: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6019 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:25.594259Z :NOTICE: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:25.594269Z :DEBUG: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] [] Abort session to cluster
2025-12-12T12:00:25.594480Z :DEBUG: [local] 0x0000302C3F740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 Close
2025-12-12T12:00:25.594558Z :DEBUG: [local] 0x0000302C3F740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_3_16833704366150282058_v1 Close
2025-12-12T12:00:25.594578Z :NOTICE: [local] [local] [edba32f6-4183f126-cd835fb4-c4891ee6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:25.594721Z :INFO: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:25.594731Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_4/topic_A:0:1:0:1
2025-12-12T12:00:25.594737Z :INFO: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8022 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:25.594745Z :NOTICE: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:25.594750Z :DEBUG: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] [] Abort session to cluster
2025-12-12T12:00:25.594838Z :DEBUG: [local] 0x0000302C3F746D10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 Close
2025-12-12T12:00:25.594857Z :DEBUG: [local] 0x0000302C3F746D10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_4-test-consumer_1_1_1471738516035482319_v1 Close
2025-12-12T12:00:25.594867Z :NOTICE: [local] [local] [e06a094e-9f76ed3d-c6847db9-6a76cc1b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:25.595055Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:25.595061Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:25.595067Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:25.595172Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:25.595177Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|143b6c49-ee5ad9ff-a2c29251-801158f8_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:00:25.595421Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:25.595426Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:25.595431Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:25.595534Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:25.595539Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a2918fd5-1fe5bdeb-a1b4ce82-d136701b_0]  PartitionId [0]  Generation [1] Write session: destroy
