2025-12-12T11:55:15.928121Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:55:15.928337Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:15.928584Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:55:15.928631Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:55:15.928744Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:15.937274Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:15.937298Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540515937 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:15.937327Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0"
2025-12-12T11:55:15.937331Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:15.937419Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:15.937471Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:15.939080Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_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:15.939100Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:15.939106Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:15.939397Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:15.939557Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:15.939587Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:55:15.939686Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:15.946233Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:15.946285Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|aea3141f-6a42da76-f0560ef-9c0435b4_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0"
2025-12-12T11:55:15.946291Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:15.946366Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mm2q4dnwqyebaqxy5y2t}, WriteCount=1, AckCount=0
2025-12-12T11:55:15.946388Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:15.946421Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:15.946427Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:15.946607Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:55:15.946858Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:55:15.947687Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:55:15.947746Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:55:15.947895Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:15.952167Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:15.952301Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_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-12T11:55:15.952317Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mm2q4dnwqyebaqxy5y2t}, WriteCount=1, AckCount=1
2025-12-12T11:55:15.952322Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:15.956565Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:15.956589Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540515956 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:15.988479Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0"
2025-12-12T11:55:15.988497Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:15.988626Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:55:15.988667Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:15.990289Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_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:15.990308Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:15.990313Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:15.990609Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:55:15.990687Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:15.990714Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:55:15.990810Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:15.997776Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:15.997821Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8d8858dd-53768113-73aded75-41da9d48_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0"
2025-12-12T11:55:15.997828Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:55:15.997898Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mm2q4dnwqyebaqxy5y2t}, WriteCount=1, AckCount=0
2025-12-12T11:55:15.997928Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:15.997952Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:15.997959Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:15.998078Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:15.998086Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:15.998089Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:15.998178Z :INFO: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Starting read session
2025-12-12T11:55:15.998188Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Starting single session
2025-12-12T11:55:15.998461Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:15.998468Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:15.998474Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:15.998733Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Successfully connected. Initializing session
2025-12-12T11:55:15.999613Z :INFO: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1
2025-12-12T11:55:15.999630Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:15.999696Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:16.000593Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:16.000658Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { } } write_statistics { persisting_time { nanos: 4000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:55:16.000665Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:55:16.000670Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:16.001307Z :INFO: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:16.001328Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:16.001367Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_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:16.001378Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mm2q4dnwqyebaqxy5y2t}, WriteCount=1, AckCount=1
2025-12-12T11:55:16.001381Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:16.001384Z :DEBUG: [local] 0x00001393BF74BB10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:16.001402Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:16.090091Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:16.090127Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:16.090130Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:16.090172Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:16.090238Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer" }
2025-12-12T11:55:16.091104Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:16.091119Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:16.091122Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:16.091135Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:16.091142Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:16.091510Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_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:16.091520Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:16.091672Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:55:16.091679Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:16.091789Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:55:16.091819Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:55:16.091861Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:55:16.091883Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:55:16.091893Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:55:16.092008Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:16.092066Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:16.092078Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:55:16.092083Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:55:16.092101Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:55:16.096963Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:55:16.999428Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_A:0:1:0:1
2025-12-12T11:55:16.999459Z :INFO: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:18.005610Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mp3na56dgn50k5vjztya}, WriteCount=1, AckCount=0
2025-12-12T11:55:18.005636Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:55:18.005657Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:18.005663Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:55:18.005773Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mp3na56dgn50k5vjztya}, WriteCount=1, AckCount=0
2025-12-12T11:55:18.005779Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:55:18.005786Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:18.005790Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:55:18.009042Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:18.009107Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 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-12T11:55:18.009122Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mp3na56dgn50k5vjztya}, WriteCount=1, AckCount=1
2025-12-12T11:55:18.009141Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:55:18.015234Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:18.015300Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_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-12T11:55:18.015323Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YTE5N2VmNmItOTcxNGVhYWUtMmYwMmYxYzgtNWNmOTQ3YzI=, 01kc96mp3na56dgn50k5vjztya}, WriteCount=1, AckCount=1
2025-12-12T11:55:18.015632Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:55:18.024804Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 1
2025-12-12T11:55:18.024826Z :DEBUG: [local] 0x00001393BFBC5DA0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:55:18.024982Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:55:18.025008Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:55:18.025048Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T11:55:18.025069Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:55:18.025076Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:55:18.025178Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:18.025251Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:55:18.025267Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:55:18.025274Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:55:18.025290Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Commit offsets [1, 2). Partition stream id: 1
2025-12-12T11:55:18.026604Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:55:20.024878Z :INFO: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Starting read session
2025-12-12T11:55:20.024894Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Starting single session
2025-12-12T11:55:20.025218Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:20.025225Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:20.025231Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:20.025568Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Successfully connected. Initializing session
2025-12-12T11:55:20.026645Z :INFO: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1
2025-12-12T11:55:20.026665Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:20.026722Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:20.027981Z :INFO: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:20.028078Z :DEBUG: [local] 0x00001393BF743910 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:20.028098Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:20.028284Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:20.028293Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:20.028297Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:20.028325Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:20.028373Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_B" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer" }
2025-12-12T11:55:20.028921Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:20.028932Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:20.028935Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:20.028951Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:20.028957Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:20.029292Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_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:20.029305Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:20.029353Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:55:20.029358Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:20.029452Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Got ReadResponse, serverBytesSize = 164, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:55:20.029471Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428636
2025-12-12T11:55:20.029520Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:55:20.029544Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Returning serverBytesSize = 164 to budget
2025-12-12T11:55:20.029552Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] In ContinueReadingDataImpl, ReadSizeBudget = 164, ReadSizeServerDelta = 52428636
2025-12-12T11:55:20.029661Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:20.029705Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:20.029719Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:55:20.029725Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Returning serverBytesSize = 0 to budget
0 1
2025-12-12T11:55:20.029740Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:55:20.030789Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:55:21.025345Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_B:0:1:0:1
2025-12-12T11:55:21.025373Z :INFO: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:22.024950Z :INFO: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:22.024981Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_B:0:1:0:1
2025-12-12T11:55:22.025010Z :INFO: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 10 MessagesRead: 1 BytesReadCompressed: 10 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:22.025035Z :NOTICE: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:22.025045Z :DEBUG: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] [] Abort session to cluster
2025-12-12T11:55:22.026060Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS stop_direct_read_partition_session { status: SESSION_EXPIRED issues { message: "Closed by server" issue_code: 500009 severity: 1 } partition_session_id: 1 }
2025-12-12T11:55:22.026082Z :DEBUG: [local] 0x00001393BFBC4D20 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 NodeId=1 Got StopDirectReadPartitionSession status: SESSION_EXPIRED issues { message: "Closed by server" issue_code: 500009 severity: 1 } partition_session_id: 1
2025-12-12T11:55:22.030941Z :DEBUG: [local] 0x00001393BF743910 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 Close
2025-12-12T11:55:22.031157Z :DEBUG: [local] 0x00001393BF743910 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_7_10136977290985684643_v1 Close
2025-12-12T11:55:22.031193Z :NOTICE: [local] [local] [b79eb76e-ea65e081-7e9b40aa-8739e711] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:22.033477Z :INFO: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:22.033496Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_3/topic_A:0:1:1:2
2025-12-12T11:55:22.033506Z :INFO: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6035 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:22.033525Z :NOTICE: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:22.033535Z :DEBUG: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] [] Abort session to cluster
2025-12-12T11:55:22.033682Z :DEBUG: [local] 0x00001393BF74BB10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 Close
2025-12-12T11:55:22.033709Z :DEBUG: [local] 0x00001393BF74BB10 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_3-test-consumer_1_5_1825180018785236398_v1 Close
2025-12-12T11:55:22.033723Z :NOTICE: [local] [local] [7659c584-bb95cc3d-96000342-29bcef2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:55:22.034053Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:22.034059Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:22.034067Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:22.034152Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:22.034157Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|d5319efc-1bec7e12-a75b8a43-79a1eda3_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:55:22.034494Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:55:22.034505Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:22.034510Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:22.034621Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:22.034626Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|57e25f8e-c40c38b4-e012dbdd-15c4a309_0]  PartitionId [0]  Generation [1] Write session: destroy
