2025-12-12T12:00:33.207251Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T12:00:33.207443Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:33.207634Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T12:00:33.207676Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T12:00:33.207785Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:33.214316Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.214335Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540833214 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:33.214357Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0"
2025-12-12T12:00:33.214360Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:33.214421Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:33.214481Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:33.216055Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_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:33.216074Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:33.216079Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:33.216437Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:33.216555Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:33.216600Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T12:00:33.216721Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:33.223355Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.223406Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|4a4205e-7296be48-763b87b3-6f55bc98_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0"
2025-12-12T12:00:33.223413Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:33.223511Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9xp1drb4v8dg6hzwjya}, WriteCount=1, AckCount=0
2025-12-12T12:00:33.223531Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:33.223555Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:33.223560Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:33.223789Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T12:00:33.224025Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T12:00:33.224314Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T12:00:33.224346Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T12:00:33.224478Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:33.227166Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.227198Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_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:33.227206Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9xp1drb4v8dg6hzwjya}, WriteCount=1, AckCount=1
2025-12-12T12:00:33.227209Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:33.231692Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.231709Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540833231 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:33.231730Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0"
2025-12-12T12:00:33.231733Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:33.231798Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:33.231858Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:33.233454Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_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:33.233472Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:33.233478Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:33.233773Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:00:33.233890Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:33.233919Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T12:00:33.234033Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:33.240939Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.240977Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|93f6faf3-b95a1a3d-77c8f587-252776f9_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0"
2025-12-12T12:00:33.240984Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:00:33.241065Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9xp1drb4v8dg6hzwjya}, WriteCount=1, AckCount=0
2025-12-12T12:00:33.241086Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:33.241113Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:33.241120Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:33.243967Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.244022Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_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:33.244033Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9xp1drb4v8dg6hzwjya}, WriteCount=1, AckCount=1
2025-12-12T12:00:33.244293Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:33.255600Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9z7bekb9x5hshwh4114}, WriteCount=1, AckCount=0
2025-12-12T12:00:33.255620Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:33.255641Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:33.255645Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:33.255752Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9z7bekb9x5hshwh4114}, WriteCount=1, AckCount=0
2025-12-12T12:00:33.255756Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:33.255763Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:33.255765Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:33.258848Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.258911Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_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:33.258924Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9z7bekb9x5hshwh4114}, WriteCount=1, AckCount=1
2025-12-12T12:00:33.258939Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:33.264062Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:33.264121Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_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:33.264132Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YTU3NjJjYWEtZTgzZjgyZTgtOGQ2NzhjOGMtYjdjNzA2MjE=, 01kc96y9z7bekb9x5hshwh4114}, WriteCount=1, AckCount=1
2025-12-12T12:00:33.264427Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:33.274680Z :INFO: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Starting read session
2025-12-12T12:00:33.274697Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Starting single session
2025-12-12T12:00:33.274965Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:33.274972Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:33.274976Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:33.275223Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Successfully connected. Initializing session
2025-12-12T12:00:33.276091Z :INFO: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1
2025-12-12T12:00:33.276109Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:33.276202Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:33.277659Z :INFO: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:33.277771Z :DEBUG: [local] 0x00003069FF740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:33.277790Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:33.277979Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:33.277986Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:33.277989Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:33.278078Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:33.278118Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer" }
2025-12-12T12:00:33.278686Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:33.278697Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:33.278699Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:33.278708Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:33.278713Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:33.278991Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_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:33.278997Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:33.279108Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T12:00:33.279118Z :DEBUG: [local] 0x00003069FFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:33.279234Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Got ReadResponse, serverBytesSize = 306, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T12:00:33.279249Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T12:00:33.279307Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:00:33.279330Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Returning serverBytesSize = 306 to budget
2025-12-12T12:00:33.279338Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] In ContinueReadingDataImpl, ReadSizeBudget = 306, ReadSizeServerDelta = 52428494
2025-12-12T12:00:33.279456Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:33.279516Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:33.279529Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:00:33.279541Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T12:00:33.279550Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T12:00:33.279577Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:00:33.280570Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T12:00:34.275375Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_A:0:1:1:2
2025-12-12T12:00:34.275405Z :INFO: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:35.274814Z :INFO: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Starting read session
2025-12-12T12:00:35.274836Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Starting single session
2025-12-12T12:00:35.275111Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:35.275118Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:35.275124Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:00:35.275483Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Successfully connected. Initializing session
2025-12-12T12:00:35.276763Z :INFO: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1
2025-12-12T12:00:35.276785Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:00:35.276831Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:35.278361Z :INFO: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T12:00:35.278485Z :DEBUG: [local] 0x00003069FF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 StartPartitionSession 1 nodeId=1
2025-12-12T12:00:35.278506Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T12:00:35.278697Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T12:00:35.278735Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_B" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer" }
2025-12-12T12:00:35.279283Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 AddPartitionSession 1
2025-12-12T12:00:35.279291Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:35.279295Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T12:00:35.279414Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T12:00:35.279428Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 Got InitResponse 
2025-12-12T12:00:35.279432Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T12:00:35.279446Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:35.279452Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T12:00:35.279819Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_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:35.279837Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T12:00:35.279905Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T12:00:35.279914Z :DEBUG: [local] 0x00003069FFBC2C20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T12:00:35.280043Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Got ReadResponse, serverBytesSize = 306, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T12:00:35.280070Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T12:00:35.280115Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:00:35.280146Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Returning serverBytesSize = 306 to budget
2025-12-12T12:00:35.280154Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] In ContinueReadingDataImpl, ReadSizeBudget = 306, ReadSizeServerDelta = 52428494
2025-12-12T12:00:35.280208Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T12:00:35.280271Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:00:35.280281Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:00:35.280293Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T12:00:35.280303Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T12:00:35.280332Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:00:35.281619Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T12:00:36.275329Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_B:0:1:1:2
2025-12-12T12:00:36.275357Z :INFO: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:37.274870Z :INFO: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:37.274903Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_B:0:1:1:2
2025-12-12T12:00:37.274916Z :INFO: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:37.274941Z :NOTICE: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:37.274952Z :DEBUG: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] [] Abort session to cluster
2025-12-12T12:00:37.275178Z :DEBUG: [local] 0x00003069FF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 Close
2025-12-12T12:00:37.275210Z :DEBUG: [local] 0x00003069FF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_7_14311692386599839080_v1 Close
2025-12-12T12:00:37.275227Z :NOTICE: [local] [local] [af9c9fd8-9da0cce0-ea7085d4-95b2d064] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:37.275396Z :INFO: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Closing read session. Close timeout: 0.000000s
2025-12-12T12:00:37.275415Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_5/topic_A:0:1:1:2
2025-12-12T12:00:37.275423Z :INFO: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:37.275436Z :NOTICE: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:00:37.275443Z :DEBUG: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] [] Abort session to cluster
2025-12-12T12:00:37.275566Z :DEBUG: [local] 0x00003069FF740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 Close
2025-12-12T12:00:37.275597Z :DEBUG: [local] 0x00003069FF740510 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_5-test-consumer_1_5_13819265479321428275_v1 Close
2025-12-12T12:00:37.275611Z :NOTICE: [local] [local] [16d376c8-808cbb86-7f5b18cd-9be8a8a6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:00:37.275918Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:37.275925Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:37.275931Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:37.276038Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:37.276044Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b8536f45-e2e6ca41-f4d22381-486b59e8_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:00:37.276267Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:00:37.276273Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:00:37.276277Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:00:37.276359Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:00:37.276364Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|ab2c3f44-cccfd340-b04a98cc-f3227e09_0]  PartitionId [0]  Generation [1] Write session: destroy
