==== TMockDiscovery server started on port 35223
==== TMockDiscovery set good endpoint nodes 
==== TMockDiscovery add endpoints, firstNodeId 1, nodeCount 1, port 1665
==== ListEndpoints request: database: "local"
==== ListEndpoints response: operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "localhost" port: 1665 node_id: 1 } } } }
=== Write message
2025-12-12T11:55:05.274681Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T11:55:05.274969Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 18446744073709.551615s
2025-12-12T11:55:05.275409Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:05.279824Z :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:55:05.279845Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:05.279850Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:05.280919Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:05.280968Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/LocalPartition-DirectRead_Basic/test-topic" producer_id: "test-producer" partition_with_generation { generation: 1 } }
2025-12-12T11:55:05.281090Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:06.073140Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:06.073173Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540506073 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:06.073206Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0"
2025-12-12T11:55:06.073275Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:55:06.073314Z :INFO: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:55:06.073517Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:55:06.073530Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:55:06.075187Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:06.075380Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_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:55:06.075388Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:55:06.075392Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:55:06.173422Z :INFO: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:06.173450Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:06.173782Z :INFO: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:06.173798Z :DEBUG: [local]  TraceId []  SessionId [test-producer|71959e3e-3adb6415-3aa7f705-5c772fb_0]  PartitionId [0]  Generation [1] Write session: destroy
=== Read message
2025-12-12T11:55:06.173859Z :INFO: [local] [local] [75174de1-97b045a3-b675f222-39392e40] Starting read session
2025-12-12T11:55:06.173864Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] Starting single session
2025-12-12T11:55:06.173977Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:06.173982Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:06.173986Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:06.174294Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Successfully connected. Initializing session
2025-12-12T11:55:06.175757Z :INFO: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Got InitResponse. ReadSessionId: LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1
2025-12-12T11:55:06.175782Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:06.175968Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:06.178636Z :INFO: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/LocalPartition-DirectRead_Basic/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:55:06.178731Z :DEBUG: [local] 0x000050467F743910 TDirectReadSessionManager ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:55:06.178757Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:55:06.179051Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:55:06.179059Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:06.179062Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:55:06.179357Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:55:06.179410Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1" topics_read_settings { path: "sdk_tests/LocalPartition-DirectRead_Basic/test-topic" } consumer: "LocalPartition-DirectRead_Basic-test-consumer" }
2025-12-12T11:55:06.180209Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:55:06.180224Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 Got InitResponse 
2025-12-12T11:55:06.180228Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:06.180244Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:06.180250Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:06.180771Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:55:06.180783Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:55:06.180980Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:55:06.180987Z :DEBUG: [local] 0x000050467FBC7920 TDirectReadSession ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:55:06.181088Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Got ReadResponse, serverBytesSize = 165, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428635
2025-12-12T11:55:06.181113Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428635
2025-12-12T11:55:06.181185Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:55:06.181197Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Returning serverBytesSize = 165 to budget
2025-12-12T11:55:06.181205Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] In ContinueReadingDataImpl, ReadSizeBudget = 165, ReadSizeServerDelta = 52428635
2025-12-12T11:55:06.181265Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:06.181328Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:55:06.181350Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] The application data is transferred to the client. Number of messages 1, size 7 bytes
2025-12-12T11:55:06.187891Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:06.187929Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:55:06.190199Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:55:06.190348Z :INFO: [local] [local] [75174de1-97b045a3-b675f222-39392e40] Closing read session. Close timeout: 0.000000s
2025-12-12T11:55:06.190384Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/LocalPartition-DirectRead_Basic/test-topic:0:1:0:1
2025-12-12T11:55:06.190395Z :INFO: [local] [local] [75174de1-97b045a3-b675f222-39392e40] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 7 MessagesRead: 1 BytesReadCompressed: 27 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:06.190417Z :NOTICE: [local] [local] [75174de1-97b045a3-b675f222-39392e40] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:55:06.190426Z :DEBUG: [local] [local] [75174de1-97b045a3-b675f222-39392e40] [] Abort session to cluster
2025-12-12T11:55:06.190595Z :DEBUG: [local] 0x000050467F743910 TDirectReadSessionManager ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 Close
2025-12-12T11:55:06.190671Z :DEBUG: [local] 0x000050467F743910 TDirectReadSessionManager ServerSessionId=LocalPartition-DirectRead_Basic-test-consumer_1_1_14191755229316278147_v1 Close
2025-12-12T11:55:06.190688Z :NOTICE: [local] [local] [75174de1-97b045a3-b675f222-39392e40] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
