2025-12-12T11:57:53.378720Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: try to update token
2025-12-12T11:57:53.378975Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:53.379270Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: write to message_group: test-message_group_id_1
2025-12-12T11:57:53.379308Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_1" message_group_id: "test-message_group_id_1" }
2025-12-12T11:57:53.379393Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:53.386269Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.386288Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540673386 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:53.386313Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_1] Write session established. Init response: session_id: "test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0"
2025-12-12T11:57:53.386317Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  MessageGroupId [test-message_group_id_1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:53.386371Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:53.386418Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:53.387734Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:53.387747Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:53.387753Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:53.388119Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:53.388275Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:53.388301Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T11:57:53.388389Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:53.394524Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.394569Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|e22f1777-709378d4-87a2cd9d-b13d8f7f_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0"
2025-12-12T11:57:53.394575Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:53.394657Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=1, AckCount=0
2025-12-12T11:57:53.394689Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:53.394716Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:53.394722Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:53.394877Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=2, AckCount=0
2025-12-12T11:57:53.394884Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:53.394890Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:53.394893Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:53.394982Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: try to update token
2025-12-12T11:57:53.395310Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:53.395596Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: write to message_group: test-message_group_id_2
2025-12-12T11:57:53.395632Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_2" message_group_id: "test-message_group_id_2" }
2025-12-12T11:57:53.395731Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:53.398869Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.398924Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_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:57:53.398940Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=2, AckCount=1
2025-12-12T11:57:53.398945Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:53.399589Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.399627Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:53.399636Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=2, AckCount=2
2025-12-12T11:57:53.399640Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:53.402236Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.402256Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540673402 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:53.402277Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id_2] Write session established. Init response: session_id: "test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0"
2025-12-12T11:57:53.402282Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  MessageGroupId [test-message_group_id_2] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:53.402343Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:53.402391Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:53.403549Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:53.403564Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:53.403569Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:53.403934Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:53.404093Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:53.404119Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { generation: 1 } }
2025-12-12T11:57:53.404255Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:53.411299Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.411362Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|4df167c-217565bc-45d7415a-db2e2eeb_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0"
2025-12-12T11:57:53.411368Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:53.411436Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:53.411469Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:53.411476Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:53.411618Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:53.411624Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:53.411627Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:53.411645Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=3, AckCount=2
2025-12-12T11:57:53.411650Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:53.411657Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:53.411661Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:53.411744Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=4, AckCount=2
2025-12-12T11:57:53.411750Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:53.411757Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:53.411760Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:53.411824Z :INFO: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Starting read session
2025-12-12T11:57:53.411828Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Starting single session
2025-12-12T11:57:53.412145Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:53.412154Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:53.412159Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:53.412450Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Successfully connected. Initializing session
2025-12-12T11:57:53.413443Z :INFO: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Got InitResponse. ReadSessionId: TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1
2025-12-12T11:57:53.413464Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:53.413541Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:53.413628Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.413673Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.413683Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } 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:57:53.413691Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:53.413696Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:53.413723Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 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:57:53.413739Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=4, AckCount=3
2025-12-12T11:57:53.413743Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:53.414495Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.414529Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { offset: 1 } } 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:57:53.414534Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:53.414538Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:53.414602Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:53.414631Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:53.414640Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=ZDU5OGQwZTgtOWQ0NTRiYWUtZjc4MGI0Y2UtNWUxYmU1ZWQ=, 01kc96sdv237mdergwect9hkj8}, WriteCount=4, AckCount=4
2025-12-12T11:57:53.414643Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:53.415087Z :INFO: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:53.415167Z :DEBUG: [local] 0x000073AEFF740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:53.415185Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:53.415377Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:53.415386Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:53.415393Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:53.415483Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:53.415519Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1" topics_read_settings { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A" } consumer: "TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer" }
2025-12-12T11:57:53.416094Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:53.416102Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:53.416105Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:53.416115Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:53.416121Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:53.416546Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:53.416557Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:53.416634Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:53.416645Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:53.416770Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Got ReadResponse, serverBytesSize = 310, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T11:57:53.416795Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428490
2025-12-12T11:57:53.416854Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:53.416878Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Returning serverBytesSize = 310 to budget
2025-12-12T11:57:53.416884Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] In ContinueReadingDataImpl, ReadSizeBudget = 310, ReadSizeServerDelta = 52428490
2025-12-12T11:57:53.416994Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:53.417047Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:53.417062Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:53.417075Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:53.417083Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Returning serverBytesSize = 0 to budget
0 2
2025-12-12T11:57:53.417105Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T11:57:53.418168Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 2 } }
2025-12-12T11:57:54.412355Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A:0:1:1:2
2025-12-12T11:57:54.412382Z :INFO: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 20 MessagesRead: 2 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:55.415107Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 2 lastOffset = 5
2025-12-12T11:57:55.415130Z :DEBUG: [local] 0x000073AEFFBCB5A0 TDirectReadSession ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:55.415317Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Got ReadResponse, serverBytesSize = 598, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428202
2025-12-12T11:57:55.415352Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428202
2025-12-12T11:57:55.415396Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-5)
2025-12-12T11:57:55.415425Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Returning serverBytesSize = 598 to budget
2025-12-12T11:57:55.415432Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] In ContinueReadingDataImpl, ReadSizeBudget = 598, ReadSizeServerDelta = 52428202
2025-12-12T11:57:55.415478Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:55.415529Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T11:57:55.415542Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T11:57:55.415549Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (4-4)
2025-12-12T11:57:55.415554Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (5-5)
2025-12-12T11:57:55.415567Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] The application data is transferred to the client. Number of messages 4, size 40 bytes
2025-12-12T11:57:55.415575Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T11:57:55.415602Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Commit offsets [2, 6). Partition stream id: 1
2025-12-12T11:57:55.416806Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 6 } }
2025-12-12T11:57:57.415028Z :INFO: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:57.415058Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Demo_7/topic_A:0:1:5:6
2025-12-12T11:57:57.415069Z :INFO: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4003 BytesRead: 60 MessagesRead: 6 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:57.415087Z :NOTICE: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:57.415097Z :DEBUG: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] [] Abort session to cluster
2025-12-12T11:57:57.415285Z :DEBUG: [local] 0x000073AEFF740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 Close
2025-12-12T11:57:57.415322Z :DEBUG: [local] 0x000073AEFF740510 TDirectReadSessionManager ServerSessionId=TxUsageQuery-DirectRead_WriteToTopic_Demo_7-test-consumer_1_19_5145177817074781212_v1 Close
2025-12-12T11:57:57.415337Z :NOTICE: [local] [local] [451117e3-b6548747-14afcd4e-b7b50cc1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:57.415492Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:57.415498Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:57.415504Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:57.415572Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:57.415577Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|feca53d1-d3e22f5c-c2e208b3-be5a3bd3_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:57.415822Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:57.415836Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:57.415842Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:57.416014Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:57.416019Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|6a0bc9ca-7fd307fc-6a5c17ac-a005bc8f_0]  PartitionId [0]  Generation [1] Write session: destroy
