2025-12-12T11:57:41.831124Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:41.831385Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:41.832655Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:41.832719Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/Describe-DirectRead_Statistics/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:41.832807Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:42.428346Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:42.428375Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540662428 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.428407Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0"
2025-12-12T11:57:42.428414Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:42.428455Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:42.428508Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:42.429801Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_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:42.429821Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:42.429827Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:42.430249Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:42.430410Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:42.430437Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/Describe-DirectRead_Statistics/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:42.430557Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:42.431548Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:42.431585Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|662458ef-4a9f7201-3204919d-15952317_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0"
2025-12-12T11:57:42.431591Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:42.467715Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:42.508011Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:42.508037Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:42.560130Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Estimated memory usage 33554432[B] reached maximum (20971520[B])
2025-12-12T11:57:42.560158Z :INFO: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:42.709429Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:42.709610Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 27000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:42.709620Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:42.709624Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:42.709629Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Estimated memory usage got back to normal 0[B]
2025-12-12T11:57:42.760305Z :INFO: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:42.760333Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:42.760676Z :INFO: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:42.760936Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:42.760951Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:42.766617Z :DEBUG: [local]  TraceId []  SessionId [2b9a5cf3-3e8f401e-eb7a5d74-6ea62706|d0da5fd3-90086ed8-a5843668-a4c92ab2_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:42.766746Z :INFO: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] Starting read session
2025-12-12T11:57:42.766753Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] Starting single session
2025-12-12T11:57:42.766785Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:42.766788Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:42.766792Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:42.767062Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Successfully connected. Initializing session
2025-12-12T11:57:42.768084Z :INFO: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Got InitResponse. ReadSessionId: Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1
2025-12-12T11:57:42.768103Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:42.768188Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:42.769740Z :INFO: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/Describe-DirectRead_Statistics/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:42.769825Z :DEBUG: [local] 0x000053477F746D10 TDirectReadSessionManager ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:42.769843Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:42.770014Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:42.770021Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:42.770026Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:42.770069Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:42.770113Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1" topics_read_settings { path: "sdk_tests/Describe-DirectRead_Statistics/test-topic" } consumer: "Describe-DirectRead_Statistics-test-consumer" }
2025-12-12T11:57:42.770817Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:42.770827Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:42.770830Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:42.770840Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:42.770846Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:42.771230Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_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.771242Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:42.919044Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 0
2025-12-12T11:57:42.919062Z :DEBUG: [local] 0x000053477FBC3720 TDirectReadSession ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:42.919249Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Got ReadResponse, serverBytesSize = 33554595, now ReadSizeBudget = 0, ReadSizeServerDelta = 18874205
2025-12-12T11:57:42.919273Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 18874205
2025-12-12T11:57:42.919326Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:42.919371Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Returning serverBytesSize = 33554595 to budget
2025-12-12T11:57:42.919378Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] In ContinueReadingDataImpl, ReadSizeBudget = 33554595, ReadSizeServerDelta = 18874205
2025-12-12T11:57:42.919529Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:42.945895Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:42.945931Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] The application data is transferred to the client. Number of messages 1, size 33554432 bytes
2025-12-12T11:57:42.945947Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:42.945993Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T11:57:42.947874Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 1 } }
2025-12-12T11:57:42.948020Z :INFO: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:42.948040Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/Describe-DirectRead_Statistics/test-topic:0:1:0:1
2025-12-12T11:57:42.948050Z :INFO: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 181 BytesRead: 33554432 MessagesRead: 1 BytesReadCompressed: 33554432 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.948070Z :NOTICE: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:42.948078Z :DEBUG: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] [] Abort session to cluster
2025-12-12T11:57:42.948243Z :DEBUG: [local] 0x000053477F746D10 TDirectReadSessionManager ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 Close
2025-12-12T11:57:42.948391Z :DEBUG: [local] 0x000053477F746D10 TDirectReadSessionManager ServerSessionId=Describe-DirectRead_Statistics-test-consumer_1_1_11428383458104206732_v1 Close
2025-12-12T11:57:42.948408Z :NOTICE: [local] [local] [6af23e75-9415298d-e4c5f24-d3b4e9b3] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:42.948502Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:42.948536Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:42.949438Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:42.949477Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/Describe-DirectRead_Statistics/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:42.949567Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:42.957474Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:42.957509Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540662957 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:42.957538Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0"
2025-12-12T11:57:42.957544Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:42.957623Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:42.957668Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:42.958953Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_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:42.958969Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:42.958974Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:42.959306Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:42.959459Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:42.959486Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/Describe-DirectRead_Statistics/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:42.959575Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:42.960674Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:42.960711Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8529b438-98271aac-cc64d3ad-50a97196_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0"
2025-12-12T11:57:42.960720Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:42.960783Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:42.960816Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:42.960822Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:42.960967Z :INFO: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:42.962425Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:42.962473Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { offset: 1 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:42.962479Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:42.962484Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:43.061067Z :INFO: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:43.061101Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:43.061518Z :INFO: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:43.061589Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:43.061607Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T11:57:43.061660Z :DEBUG: [local]  TraceId []  SessionId [b3712e6-d49862fd-b00209d2-1f51139f|82d761b5-5d989a0b-7b155327-ed80e8a5_0]  PartitionId [0]  Generation [1] Write session: destroy
