2025-12-12T11:56:54.662135Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T11:56:54.662326Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:56:54.662354Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:56:54.663533Z :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:56:54.663551Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:56:54.663556Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:56:54.663721Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:56:54.663756Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_37/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:56:54.663862Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:56:54.668385Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:56:54.668403Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540614668 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:56:54.668425Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0"
2025-12-12T11:56:54.668481Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmg4b2k3wyh5ek41xq9f}, WriteCount=1, AckCount=0
2025-12-12T11:56:54.669228Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:56:54.669959Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:56:54.669972Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:56:54.672400Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmg4b2k3wyh5ek41xq9f}, WriteCount=2, AckCount=0
2025-12-12T11:56:54.672417Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:56:54.672432Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:56:54.672436Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:56:54.692988Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:56:54.693082Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 13000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:56:54.693099Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmg4b2k3wyh5ek41xq9f}, WriteCount=2, AckCount=1
2025-12-12T11:56:54.693104Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:56:54.693556Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:56:54.693585Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_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: 3000000 } max_queue_wait_time { nanos: 3000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:56:54.693592Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmg4b2k3wyh5ek41xq9f}, WriteCount=2, AckCount=2
2025-12-12T11:56:54.693823Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:56:54.705358Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmhgb8qpan3g2c3q89v2}, WriteCount=1, AckCount=0
2025-12-12T11:56:54.706016Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:56:54.706762Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:56:54.706774Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:56:54.709232Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=4, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmhgb8qpan3g2c3q89v2}, WriteCount=2, AckCount=0
2025-12-12T11:56:54.709247Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T11:56:54.709264Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:56:54.709267Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:56:54.727347Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:56:54.727422Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } write_statistics { persisting_time { nanos: 11000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:56:54.727437Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmhgb8qpan3g2c3q89v2}, WriteCount=2, AckCount=1
2025-12-12T11:56:54.727442Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:56:54.728250Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:56:54.728290Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_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: 4000000 } max_queue_wait_time { nanos: 4000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:56:54.728301Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId={ydb://session/3?node_id=1&id=MjU1NmI2NmItNTNlMzQxOC1hY2IxNGQ3My1hYWFjYWIx, 01kc96qmhgb8qpan3g2c3q89v2}, WriteCount=2, AckCount=2
2025-12-12T11:56:54.728582Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T11:56:54.730216Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:56:54.730226Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:56:54.730231Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:56:54.730364Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:56:54.730369Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|a27f7932-b0ec9119-a3ebd0d8-b547aa7d_0]  PartitionId [0]  Generation [1] Write session: destroy
