2025-12-12T11:57:23.621051Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:23.621214Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:23.625576Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:23.625620Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:23.625701Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:23.633076Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.633106Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540643633 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:23.633140Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0"
2025-12-12T11:57:23.633148Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:23.633182Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:23.633233Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:23.634530Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_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:23.634544Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:23.634562Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:23.634805Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:23.634898Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:23.634918Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken/test-topic" partition_with_generation { generation: 1 } }
2025-12-12T11:57:23.634997Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:23.635814Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.635840Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|c0fbdbe9-135e632c-a79e6215-acb7905a_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0"
2025-12-12T11:57:23.635844Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:23.635889Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:23.635909Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:23.635913Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:23.636072Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:23.636096Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:23.636098Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:23.637551Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.637591Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_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:57:23.637607Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:23.637612Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:23.638040Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.638070Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_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 { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:23.638075Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:23.638077Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:23.638120Z :INFO: [local] [local] [46337553-c54d6186-45b85b1-ae341750] Starting read session
2025-12-12T11:57:23.638130Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] Starting single session
2025-12-12T11:57:23.638168Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:23.638171Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:23.638175Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Reconnecting session to cluster  in 0.000000s
Get event on client
2025-12-12T11:57:23.638451Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Successfully connected. Initializing session
2025-12-12T11:57:23.639210Z :INFO: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Got InitResponse. ReadSessionId: BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1
2025-12-12T11:57:23.639225Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:23.639291Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:23.640863Z :INFO: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:23.640967Z :DEBUG: [local] 0x00005287FF74FC10 TDirectReadSessionManager ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:23.640988Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:23.641137Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:23.641144Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:23.641148Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 SendStartRequestImpl bail out 1
Get event on client
2025-12-12T11:57:23.641190Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:23.641230Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1" topics_read_settings { path: "sdk_tests/BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken/test-topic" } consumer: "BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer" }
2025-12-12T11:57:23.642004Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:23.642016Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:23.642019Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:23.642031Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:23.642037Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:23.642419Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_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:23.642433Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:23.642489Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:57:23.642493Z :DEBUG: [local] 0x00005287FF601620 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:23.642611Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Got ReadResponse, serverBytesSize = 284, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428516
2025-12-12T11:57:23.642636Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428516
2025-12-12T11:57:23.643548Z :INFO: [local] Error decompressing data: (TZLibDecompressorError) util/stream/zlib.cpp:143: inflate error(incorrect header check)
2025-12-12T11:57:23.643571Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T11:57:23.643593Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Returning serverBytesSize = 284 to budget
2025-12-12T11:57:23.643597Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] In ContinueReadingDataImpl, ReadSizeBudget = 284, ReadSizeServerDelta = 52428516
2025-12-12T11:57:23.643692Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:23.643732Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:23.643742Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:23.643751Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] The application data is transferred to the client. Number of messages 2, size 23 bytes
2025-12-12T11:57:23.643757Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:23.643906Z :INFO: [local] [local] [46337553-c54d6186-45b85b1-ae341750] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:23.643912Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken/test-topic:0:1:1:0
2025-12-12T11:57:23.643917Z :INFO: [local] [local] [46337553-c54d6186-45b85b1-ae341750] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5 BytesRead: 23 MessagesRead: 2 BytesReadCompressed: 43 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:23.643934Z :NOTICE: [local] [local] [46337553-c54d6186-45b85b1-ae341750] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:23.643939Z :DEBUG: [local] [local] [46337553-c54d6186-45b85b1-ae341750] [] Abort session to cluster
2025-12-12T11:57:23.644041Z :DEBUG: [local] 0x00005287FF74FC10 TDirectReadSessionManager ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 Close
2025-12-12T11:57:23.644057Z :DEBUG: [local] 0x00005287FF74FC10 TDirectReadSessionManager ServerSessionId=BasicUsage-DirectRead_TWriteSession_WriteEncoded_Broken-test-consumer_1_17_4593393777761036767_v1 Close
2025-12-12T11:57:23.644068Z :NOTICE: [local] [local] [46337553-c54d6186-45b85b1-ae341750] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:23.644109Z :INFO: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:23.644130Z :INFO: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:23.644137Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:23.644155Z :INFO: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:23.644157Z :DEBUG: [local]  TraceId []  SessionId [16a9b843-6fea3010-b504923-dce2c1ce|44800c8f-f0419d5f-e75a7b2-f66e26aa_0]  PartitionId [0]  Generation [1] Write session: destroy
