2025-12-12T11:55:24.301866Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:55:24.302073Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:24.302270Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T11:55:24.302304Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:55:24.302392Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:24.308971Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:24.308990Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540524308 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:24.309015Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0"
2025-12-12T11:55:24.309019Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:24.309089Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:24.309166Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:24.310504Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:24.310518Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:24.310524Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:24.310857Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:24.311008Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:24.311035Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:55:24.311137Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:24.317016Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:24.317056Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c9d739ed-91e0b4a7-bbf964c6-ad7d0903_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0"
2025-12-12T11:55:24.317062Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:24.317126Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZWY0ZGNmZmEtYWYyMmViZWYtMTczMTg3MDMtMTY1ODFiOTg=, 01kc96mw8dbjgpvt4456py7gk7}, WriteCount=1, AckCount=0
2025-12-12T11:55:24.317144Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:24.317164Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:24.317186Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:24.317296Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:55:24.320972Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:24.321031Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 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-12T11:55:24.321044Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZWY0ZGNmZmEtYWYyMmViZWYtMTczMTg3MDMtMTY1ODFiOTg=, 01kc96mw8dbjgpvt4456py7gk7}, WriteCount=1, AckCount=1
2025-12-12T11:55:24.321049Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:24.417411Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:24.417438Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:24.417791Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:24.417804Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:24.417818Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:55:24.417842Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|c2ff31eb-82188657-697dc24-412274fb_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:24.418202Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:55:24.418386Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:24.418657Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T11:55:24.418711Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:55:24.418889Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:24.427574Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:24.427600Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540524427 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:24.427631Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0"
2025-12-12T11:55:24.427637Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:24.427712Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:24.427754Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:24.429089Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:24.429106Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:24.429114Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:24.429741Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:24.429809Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:24.429833Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:55:24.429919Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:24.437045Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:24.437090Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|5610845-91a7797-60aad52f-3d825aaa_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0"
2025-12-12T11:55:24.437098Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:24.437198Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZWY0ZGNmZmEtYWYyMmViZWYtMTczMTg3MDMtMTY1ODFiOTg=, 01kc96mw8dbjgpvt4456py7gk7}, WriteCount=1, AckCount=0
2025-12-12T11:55:24.437219Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:24.437242Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:24.437249Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:24.437425Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:55:24.439450Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:24.439501Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 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-12T11:55:24.439512Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZWY0ZGNmZmEtYWYyMmViZWYtMTczMTg3MDMtMTY1ODFiOTg=, 01kc96mw8dbjgpvt4456py7gk7}, WriteCount=1, AckCount=1
2025-12-12T11:55:24.439516Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:24.537536Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:24.537560Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:24.537810Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:24.537824Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3005c8a6-acb581fb-2a101fed-e911126f_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:24.540521Z :INFO: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Starting read session
2025-12-12T11:55:24.540534Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Starting single session
2025-12-12T11:55:24.540740Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:24.540744Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:24.540761Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:24.540994Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Successfully connected. Initializing session
2025-12-12T11:55:24.542320Z :INFO: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1
2025-12-12T11:55:24.542339Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:24.542409Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:24.543363Z :INFO: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:24.543466Z :DEBUG: [local] 0x00001393BF741210 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:24.543487Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:24.543661Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:24.543667Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:24.543671Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:24.543724Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:24.543781Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer" }
2025-12-12T11:55:24.544470Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:24.544481Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:24.544484Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:24.544497Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:24.544503Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:24.544956Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:24.544968Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:24.545490Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:55:24.545500Z :DEBUG: [local] 0x00001393BFBC9A20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:24.545619Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Got ReadResponse, serverBytesSize = 310, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T11:55:24.545655Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T11:55:24.545694Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:55:24.545708Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Returning serverBytesSize = 310 to budget
2025-12-12T11:55:24.545715Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] In ContinueReadingDataImpl, ReadSizeBudget = 310, ReadSizeServerDelta = 52428490
2025-12-12T11:55:24.545807Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:24.545856Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:24.545871Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:55:24.631749Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:55:24.631775Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:55:24.631829Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:55:24.636269Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:55:25.541342Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A:0:1:1:2
2025-12-12T11:55:25.541374Z :INFO: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:26.540597Z :INFO: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:26.540628Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_15/topic_A:0:1:1:2
2025-12-12T11:55:26.540639Z :INFO: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:26.540663Z :NOTICE: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:26.540675Z :DEBUG: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] [] Abort session to cluster
2025-12-12T11:55:26.540891Z :DEBUG: [local] 0x00001393BF741210 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 Close
2025-12-12T11:55:26.540923Z :DEBUG: [local] 0x00001393BF741210 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_15-test-consumer_1_11_10343795177765708206_v1 Close
2025-12-12T11:55:26.540939Z :NOTICE: [local] [local] [5497ce78-1e3b4f19-b8fe6ed0-c9650656] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
