2025-12-12T11:57:56.643981Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T11:57:56.644201Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:56.644262Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:56.653391Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:56.653414Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:56.653422Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:56.653714Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:56.653753Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_26/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:56.653872Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:56.660056Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:56.660081Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540676660 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:56.660109Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0"
2025-12-12T11:57:56.660197Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:56.660225Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:56.660234Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:56.660349Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:56.660355Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:56.660358Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:56.660364Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:56.660367Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:56.660370Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:56.662748Z :INFO: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Starting read session
2025-12-12T11:57:56.662763Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Starting single session
2025-12-12T11:57:56.663024Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:56.663029Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:56.663034Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:56.663234Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Successfully connected. Initializing session
2025-12-12T11:57:56.663993Z :INFO: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1
2025-12-12T11:57:56.664013Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:56.664082Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:56.665774Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:56.665844Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_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 { nanos: 3000000 } max_queue_wait_time { nanos: 3000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:56.665869Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:56.665875Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:56.666419Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:56.666448Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:56.666452Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:56.666454Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:56.666690Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:56.666707Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written { offset: 2 } } 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:56.666710Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T11:57:56.666713Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:56.666728Z :INFO: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_26/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:56.666838Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:56.666860Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:56.667051Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:56.667058Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:56.667065Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:56.667092Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:56.667120Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_26/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer" }
2025-12-12T11:57:56.667625Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:56.667634Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:56.667637Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:56.667645Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:56.667651Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:56.668002Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_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:56.668010Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:56.668083Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:56.668095Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:56.668189Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 1 lastOffset = 2
2025-12-12T11:57:56.668194Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Got ReadResponse, serverBytesSize = 165, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428635
2025-12-12T11:57:56.668204Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:56.668236Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428635
2025-12-12T11:57:56.668258Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Got ReadResponse, serverBytesSize = 306, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428329
2025-12-12T11:57:56.668275Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428329
2025-12-12T11:57:56.668310Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:56.668327Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Returning serverBytesSize = 165 to budget
2025-12-12T11:57:56.668333Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] In ContinueReadingDataImpl, ReadSizeBudget = 165, ReadSizeServerDelta = 52428329
2025-12-12T11:57:56.668357Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-2)
2025-12-12T11:57:56.668446Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428494
2025-12-12T11:57:56.668464Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Returning serverBytesSize = 306 to budget
2025-12-12T11:57:56.668510Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:56.668521Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T11:57:56.668527Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-12-12T11:57:56.668538Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] The application data is transferred to the client. Number of messages 1, size 10 bytes
2025-12-12T11:57:56.668544Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] The application data is transferred to the client. Number of messages 2, size 20 bytes
2025-12-12T11:57:56.668549Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:56.668561Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:57:57.663343Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_26/topic_A:0:1:2:0
2025-12-12T11:57:57.663377Z :INFO: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:58.662839Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=ODA5MTA5NWItNzQ4MjEzYTUtMTY0MWYwN2MtZmIwYWMwNzQ=, 01kc96sh1p2cbqcawtajdgnkhm}, WriteCount=1, AckCount=0
2025-12-12T11:57:58.662864Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:58.662887Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:58.662894Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:58.663077Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=5, txId={ydb://session/3?node_id=1&id=ODA5MTA5NWItNzQ4MjEzYTUtMTY0MWYwN2MtZmIwYWMwNzQ=, 01kc96sh1p2cbqcawtajdgnkhm}, WriteCount=2, AckCount=0
2025-12-12T11:57:58.663082Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 5 to 5
2025-12-12T11:57:58.663088Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:58.663091Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-12-12T11:57:58.663096Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=6, txId={ydb://session/3?node_id=1&id=ODA5MTA5NWItNzQ4MjEzYTUtMTY0MWYwN2MtZmIwYWMwNzQ=, 01kc96sh1p2cbqcawtajdgnkhm}, WriteCount=3, AckCount=0
2025-12-12T11:57:58.663101Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 6 to 6
2025-12-12T11:57:58.663104Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:58.663107Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 6
2025-12-12T11:57:58.677065Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:58.677134Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written_in_tx { } } write_statistics { persisting_time { } min_queue_wait_time { nanos: 10000000 } max_queue_wait_time { nanos: 10000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:58.677148Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=ODA5MTA5NWItNzQ4MjEzYTUtMTY0MWYwN2MtZmIwYWMwNzQ=, 01kc96sh1p2cbqcawtajdgnkhm}, WriteCount=3, AckCount=1
2025-12-12T11:57:58.677152Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:57:58.677546Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:58.677584Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_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 { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:58.677593Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnAck: seqNo=5, txId={ydb://session/3?node_id=1&id=ODA5MTA5NWItNzQ4MjEzYTUtMTY0MWYwN2MtZmIwYWMwNzQ=, 01kc96sh1p2cbqcawtajdgnkhm}, WriteCount=3, AckCount=2
2025-12-12T11:57:58.677597Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 5
2025-12-12T11:57:58.677644Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:58.677657Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 6 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:58.677661Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] OnAck: seqNo=6, txId={ydb://session/3?node_id=1&id=ODA5MTA5NWItNzQ4MjEzYTUtMTY0MWYwN2MtZmIwYWMwNzQ=, 01kc96sh1p2cbqcawtajdgnkhm}, WriteCount=3, AckCount=3
2025-12-12T11:57:58.677916Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 6
2025-12-12T11:57:58.679905Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 3 firstOffset = 3 lastOffset = 5
2025-12-12T11:57:58.679917Z :DEBUG: [local] 0x000071673FBC8F20 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 NodeId=1 Waiting for NextDirectReadId=3. Got DirectReadResponse 3
2025-12-12T11:57:58.680052Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Got ReadResponse, serverBytesSize = 457, now ReadSizeBudget = 306, ReadSizeServerDelta = 52428037
2025-12-12T11:57:58.680079Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] In ContinueReadingDataImpl, ReadSizeBudget = 306, ReadSizeServerDelta = 52428037
2025-12-12T11:57:58.680084Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:57:58.680132Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (3-5)
2025-12-12T11:57:58.680148Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Returning serverBytesSize = 457 to budget
2025-12-12T11:57:58.680211Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-12T11:57:58.680225Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (4-4)
2025-12-12T11:57:58.680230Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (5-5)
2025-12-12T11:57:58.680241Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:57:58.680249Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:57:58.680276Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Commit offsets [3, 6). Partition stream id: 1
2025-12-12T11:58:00.679864Z :INFO: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Closing read session. Close timeout: 0.000000s
2025-12-12T11:58:00.679893Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_26/topic_A:0:1:5:0
2025-12-12T11:58:00.679905Z :INFO: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4017 BytesRead: 60 MessagesRead: 6 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:58:00.679929Z :NOTICE: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:58:00.679939Z :DEBUG: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] [] Abort session to cluster
2025-12-12T11:58:00.680211Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 Close
2025-12-12T11:58:00.680248Z :DEBUG: [local] 0x000071673F746010 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_26-test-consumer_1_19_18035668629631614581_v1 Close
2025-12-12T11:58:00.680265Z :NOTICE: [local] [local] [6fa26d6d-32428376-c4dd9b22-5f99f769] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:58:00.680449Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:58:00.680453Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:58:00.680459Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:58:00.680597Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:58:00.680602Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|771ffdab-106e3b7f-7f7a023e-a1f33485_0]  PartitionId [0]  Generation [1] Write session: destroy
