2025-12-12T11:57:40.944870Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:40.945045Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:40.945212Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:40.945265Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:40.945345Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.952436Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.952459Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540660952 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.952485Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0"
2025-12-12T11:57:40.952489Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.952559Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:40.952605Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:40.953939Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_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:40.953967Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:40.953972Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:40.954189Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.954268Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:40.954288Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:40.954362Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.959683Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.959719Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a46f0916-e6688eff-b502c9d5-3a3bbb34_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0"
2025-12-12T11:57:40.959726Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.959793Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=1, AckCount=0
2025-12-12T11:57:40.959807Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:40.959827Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.959831Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:40.959957Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=2, AckCount=0
2025-12-12T11:57:40.959961Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:40.959970Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.959972Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:40.959978Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=3, AckCount=0
2025-12-12T11:57:40.959982Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:40.959989Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.959992Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:40.960089Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=4, AckCount=0
2025-12-12T11:57:40.960093Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:40.960096Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.960102Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:40.960209Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:40.960445Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:40.960692Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:40.960724Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:40.960841Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.963275Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.963311Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_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:40.963320Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=4, AckCount=1
2025-12-12T11:57:40.963324Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:40.963836Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.963859Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_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:40.963867Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=4, AckCount=2
2025-12-12T11:57:40.963870Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:40.963925Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.963938Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:40.963945Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=4, AckCount=3
2025-12-12T11:57:40.963948Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:40.963972Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.963983Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_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:40.963987Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=4, AckCount=4
2025-12-12T11:57:40.963989Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:40.965708Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.965722Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540660965 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:40.965735Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0"
2025-12-12T11:57:40.965740Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.965789Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:40.965829Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:40.967036Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_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:40.967051Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:40.967056Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:40.967310Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:40.967389Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:40.967411Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:40.967501Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:40.972053Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.972079Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b0754c43-3d3ec5ba-8306ba0f-5de3de5c_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0"
2025-12-12T11:57:40.972085Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:40.972151Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=1, AckCount=0
2025-12-12T11:57:40.972185Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:40.972216Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.972222Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:40.972327Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=2, AckCount=0
2025-12-12T11:57:40.972332Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:40.972337Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.972340Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:40.972349Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=3, AckCount=0
2025-12-12T11:57:40.972355Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:40.972358Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.972359Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:40.972462Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=4, AckCount=0
2025-12-12T11:57:40.972465Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:40.972468Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.972470Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:40.972473Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=5, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=5, AckCount=0
2025-12-12T11:57:40.972476Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 5 to 5
2025-12-12T11:57:40.972478Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:40.972480Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-12-12T11:57:40.972525Z :INFO: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Starting read session
2025-12-12T11:57:40.972529Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Starting single session
2025-12-12T11:57:40.972755Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.972759Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.972763Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:40.972970Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Successfully connected. Initializing session
2025-12-12T11:57:40.973556Z :INFO: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1
2025-12-12T11:57:40.973571Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:40.973630Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:40.974495Z :INFO: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:40.974584Z :DEBUG: [local] 0x000073AEFF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:40.974597Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:40.974734Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:40.974739Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.974741Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:40.974760Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:40.974794Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer" }
2025-12-12T11:57:40.975322Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:40.975334Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:40.975338Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:40.975350Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.975355Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:40.975354Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.975386Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_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:40.975396Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=5, AckCount=1
2025-12-12T11:57:40.975400Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:40.975623Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_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:40.975629Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:40.976014Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.976038Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_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:40.976044Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=5, AckCount=2
2025-12-12T11:57:40.976047Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:40.976161Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.976184Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:40.976188Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=5, AckCount=3
2025-12-12T11:57:40.976191Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:40.976223Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.976234Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_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:40.976241Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=5, AckCount=4
2025-12-12T11:57:40.976243Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:40.976258Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:40.976265Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 5 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:40.976267Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] OnAck: seqNo=5, txId={ydb://session/3?node_id=1&id=ZGE2NzBjYzItMzNhNzhiYTItMmNjMTYwNjAtOGE3Yzc1YzM=, 01kc96s1pg07z8gsrsbzmbvgxz}, WriteCount=5, AckCount=5
2025-12-12T11:57:40.976269Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 5
2025-12-12T11:57:41.973323Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_A:0:1:0:0
2025-12-12T11:57:41.973346Z :INFO: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.974888Z :INFO: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Starting read session
2025-12-12T11:57:42.974909Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Starting single session
2025-12-12T11:57:42.975197Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:42.975204Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:42.975209Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:42.975534Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Successfully connected. Initializing session
2025-12-12T11:57:42.976783Z :INFO: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1
2025-12-12T11:57:42.976805Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:42.976849Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:42.978216Z :INFO: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:42.978323Z :DEBUG: [local] 0x000073AEFF748710 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:42.978355Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:42.978535Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:42.978541Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:42.978545Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:42.978582Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:42.978627Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_B" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer" }
2025-12-12T11:57:42.979165Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:42.979175Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:42.979178Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:42.979193Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:42.979198Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:42.979543Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_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:42.979554Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:43.975357Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_B:0:1:0:0
2025-12-12T11:57:43.975382Z :INFO: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:44.986362Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 4
2025-12-12T11:57:44.986374Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 3
2025-12-12T11:57:44.986382Z :DEBUG: [local] 0x000073AEFFBC10A0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:44.986393Z :DEBUG: [local] 0x000073AEFFBC4220 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:44.986476Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Got ReadResponse, serverBytesSize = 599, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428201
2025-12-12T11:57:44.986514Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Got ReadResponse, serverBytesSize = 741, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428059
2025-12-12T11:57:44.986522Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428201
2025-12-12T11:57:44.986540Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428059
2025-12-12T11:57:44.986579Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-4)
2025-12-12T11:57:44.986578Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-3)
2025-12-12T11:57:44.986612Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Returning serverBytesSize = 741 to budget
2025-12-12T11:57:44.986621Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] In ContinueReadingDataImpl, ReadSizeBudget = 741, ReadSizeServerDelta = 52428059
2025-12-12T11:57:44.986629Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Returning serverBytesSize = 599 to budget
2025-12-12T11:57:44.986641Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] In ContinueReadingDataImpl, ReadSizeBudget = 599, ReadSizeServerDelta = 52428201
2025-12-12T11:57:44.986702Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:44.986729Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:44.986786Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:44.986802Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:44.986809Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:57:44.986813Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-12T11:57:44.986826Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] The application data is transferred to the client. Number of messages 4, size 40 bytes
2025-12-12T11:57:44.986835Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Returning serverBytesSize = 0 to budget
0 4
2025-12-12T11:57:44.986866Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Commit offsets [0, 4). Partition stream id: 1
2025-12-12T11:57:44.988129Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 4 } }
2025-12-12T11:57:46.986279Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:46.986294Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:46.986298Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:57:46.986302Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-12T11:57:46.986306Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-12-12T11:57:46.986318Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] The application data is transferred to the client. Number of messages 5, size 50 bytes
2025-12-12T11:57:46.986329Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Returning serverBytesSize = 0 to budget
0 5
2025-12-12T11:57:46.986354Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Commit offsets [0, 5). Partition stream id: 1
2025-12-12T11:57:46.988311Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 5 } }
2025-12-12T11:57:48.986371Z :INFO: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:48.986395Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_B:0:1:4:5
2025-12-12T11:57:48.986404Z :INFO: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 6011 BytesRead: 50 MessagesRead: 5 BytesReadCompressed: 50 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:48.986426Z :NOTICE: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:48.986434Z :DEBUG: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] [] Abort session to cluster
2025-12-12T11:57:48.986652Z :DEBUG: [local] 0x000073AEFF748710 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 Close
2025-12-12T11:57:48.986676Z :DEBUG: [local] 0x000073AEFF748710 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_15_13259207852126071062_v1 Close
2025-12-12T11:57:48.986690Z :NOTICE: [local] [local] [87d69f85-7366b0b3-51934d5b-45fe6f0f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:48.986839Z :INFO: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:48.986846Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_1/topic_A:0:1:3:4
2025-12-12T11:57:48.986849Z :INFO: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8014 BytesRead: 40 MessagesRead: 4 BytesReadCompressed: 40 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:48.986852Z :NOTICE: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:48.986856Z :DEBUG: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] [] Abort session to cluster
2025-12-12T11:57:48.986875Z :DEBUG: [local] 0x000073AEFF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 Close
2025-12-12T11:57:48.986887Z :DEBUG: [local] 0x000073AEFF749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_1-test-consumer_1_13_17794474252341244997_v1 Close
2025-12-12T11:57:48.986892Z :NOTICE: [local] [local] [97feabaa-59ee1850-85558bc0-9e12d0e1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:48.987132Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:48.987143Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:48.987149Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:48.987268Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:48.987273Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f307c6eb-d7aa2596-ee507bea-4ddc8f3f_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:48.987489Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:48.987494Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:48.987502Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:48.987646Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:48.987657Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:48.987668Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:48.987683Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|b06fa052-68c59c9c-5e8efccc-a9d522_0]  PartitionId [0]  Generation [1] Write session: destroy
