2025-12-12T11:57:52.523995Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:52.524253Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:52.530308Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:52.530350Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_A" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:52.530435Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:52.537805Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:52.537829Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540672537 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:52.537862Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0"
2025-12-12T11:57:52.537869Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:52.537905Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:52.537951Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:52.539351Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_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:52.539368Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:52.539374Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:52.539691Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:52.539818Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:52.539846Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:52.539944Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:52.546928Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:52.546975Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|2a9cbe8c-4dc60822-f8384c8f-8ec86ff4_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0"
2025-12-12T11:57:52.546983Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:52.547051Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:52.547080Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:52.547087Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:52.547222Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:52.547229Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:52.547232Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:52.547238Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:52.547242Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:52.547245Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:52.548823Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:52.548865Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_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:52.548870Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:52.548873Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:52.549492Z :INFO: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Starting read session
2025-12-12T11:57:52.549502Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Starting single session
2025-12-12T11:57:52.549506Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:52.549526Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_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:52.549543Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T11:57:52.549547Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:52.549652Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:52.549690Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_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 { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:52.549695Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T11:57:52.549699Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:52.549747Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:52.549752Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:52.549758Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:52.549912Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Successfully connected. Initializing session
2025-12-12T11:57:52.550747Z :INFO: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1
2025-12-12T11:57:52.550766Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:52.550836Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:52.551978Z :INFO: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_A". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:52.552062Z :DEBUG: [local] 0x000071673F74AE10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:52.552084Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:52.552254Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:52.552260Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:52.552267Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:52.552303Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:52.552357Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_A" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer" }
2025-12-12T11:57:52.552898Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:52.552908Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:52.552912Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:52.552923Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:52.552929Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:52.553374Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_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:52.553386Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:52.553447Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 2
2025-12-12T11:57:52.553452Z :DEBUG: [local] 0x000071673FBC3CA0 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:52.553601Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Got ReadResponse, serverBytesSize = 457, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:57:52.553629Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:57:52.553689Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-2)
2025-12-12T11:57:52.553719Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Returning serverBytesSize = 457 to budget
2025-12-12T11:57:52.553725Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] In ContinueReadingDataImpl, ReadSizeBudget = 457, ReadSizeServerDelta = 52428343
2025-12-12T11:57:52.553891Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:52.553956Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:52.553969Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:52.553974Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:57:52.553986Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:57:52.553995Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:57:53.550366Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_A:0:1:2:0
2025-12-12T11:57:53.550411Z :INFO: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:54.549611Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:54.549848Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:54.550224Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:54.550275Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_B" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:54.550466Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:54.556822Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:54.556844Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540674556 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:54.556874Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0"
2025-12-12T11:57:54.556879Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:54.556908Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:54.556958Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:54.558299Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_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:54.558316Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:54.558321Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:54.558551Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:54.558702Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:54.558727Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_B" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:54.558816Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:54.565129Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:54.565184Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|453c41ba-b2fe9985-53c01f65-f946b15b_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0"
2025-12-12T11:57:54.565192Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:54.565266Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=YjViYmQ2OWQtZjk0YjE3MGYtNDlhMDBlZWEtY2UwMzkwMzc=, 01kc96sd159c9xvw83bpxvtgg5}, WriteCount=1, AckCount=0
2025-12-12T11:57:54.565284Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:54.565306Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:54.565312Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:54.565422Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=YjViYmQ2OWQtZjk0YjE3MGYtNDlhMDBlZWEtY2UwMzkwMzc=, 01kc96sd159c9xvw83bpxvtgg5}, WriteCount=2, AckCount=0
2025-12-12T11:57:54.565426Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:54.565432Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:54.565433Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:54.565438Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=3, txId={ydb://session/3?node_id=1&id=YjViYmQ2OWQtZjk0YjE3MGYtNDlhMDBlZWEtY2UwMzkwMzc=, 01kc96sd159c9xvw83bpxvtgg5}, WriteCount=3, AckCount=0
2025-12-12T11:57:54.565441Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:54.565444Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:54.565446Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:54.569058Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:54.569120Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 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:54.569128Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=YjViYmQ2OWQtZjk0YjE3MGYtNDlhMDBlZWEtY2UwMzkwMzc=, 01kc96sd159c9xvw83bpxvtgg5}, WriteCount=3, AckCount=1
2025-12-12T11:57:54.569136Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:54.569897Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:54.569922Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_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: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:54.569928Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=YjViYmQ2OWQtZjk0YjE3MGYtNDlhMDBlZWEtY2UwMzkwMzc=, 01kc96sd159c9xvw83bpxvtgg5}, WriteCount=3, AckCount=2
2025-12-12T11:57:54.569931Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T11:57:54.570055Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:54.570096Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written_in_tx { } } 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:54.570105Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId={ydb://session/3?node_id=1&id=YjViYmQ2OWQtZjk0YjE3MGYtNDlhMDBlZWEtY2UwMzkwMzc=, 01kc96sd159c9xvw83bpxvtgg5}, WriteCount=3, AckCount=3
2025-12-12T11:57:54.570394Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T11:57:54.575835Z :INFO: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Starting read session
2025-12-12T11:57:54.575849Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Starting single session
2025-12-12T11:57:54.576101Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:54.576106Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:54.576111Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:54.576422Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Successfully connected. Initializing session
2025-12-12T11:57:54.577271Z :INFO: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Got InitResponse. ReadSessionId: TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1
2025-12-12T11:57:54.577291Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:54.577375Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:54.578232Z :INFO: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_B". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:54.578329Z :DEBUG: [local] 0x000071673F749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:54.578349Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:54.578632Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:54.578644Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:54.578647Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:54.578677Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:54.578721Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1" topics_read_settings { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_B" } consumer: "TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer" }
2025-12-12T11:57:54.579278Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:54.579288Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:54.579291Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:54.579301Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:54.579305Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:54.579659Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_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:54.579674Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:54.579776Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 2
2025-12-12T11:57:54.579788Z :DEBUG: [local] 0x000071673FBCD120 TDirectReadSession ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:54.579915Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Got ReadResponse, serverBytesSize = 457, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:57:54.579954Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428343
2025-12-12T11:57:54.579994Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-2)
2025-12-12T11:57:54.580013Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Returning serverBytesSize = 457 to budget
2025-12-12T11:57:54.580018Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] In ContinueReadingDataImpl, ReadSizeBudget = 457, ReadSizeServerDelta = 52428343
2025-12-12T11:57:54.580053Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:54.580113Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:54.580126Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:54.580131Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T11:57:54.580144Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] The application data is transferred to the client. Number of messages 3, size 30 bytes
2025-12-12T11:57:54.580153Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Returning serverBytesSize = 0 to budget
0 3
2025-12-12T11:57:54.580192Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Commit offsets [0, 3). Partition stream id: 1
2025-12-12T11:57:54.581447Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 3 } }
2025-12-12T11:57:55.576351Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_B:0:1:2:3
2025-12-12T11:57:55.576380Z :INFO: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:56.575891Z :INFO: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:56.575916Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_B:0:1:2:3
2025-12-12T11:57:56.575924Z :INFO: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2000 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:56.575954Z :NOTICE: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:56.575964Z :DEBUG: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] [] Abort session to cluster
2025-12-12T11:57:56.576283Z :DEBUG: [local] 0x000071673F749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 Close
2025-12-12T11:57:56.576355Z :DEBUG: [local] 0x000071673F749410 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_17_6005307293545338183_v1 Close
2025-12-12T11:57:56.576374Z :NOTICE: [local] [local] [a40e3e27-703d4aca-85ea13b-78d166ff] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:56.576634Z :INFO: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:56.576651Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_25/topic_A:0:1:2:0
2025-12-12T11:57:56.576658Z :INFO: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4027 BytesRead: 30 MessagesRead: 3 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:56.576669Z :NOTICE: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T11:57:56.576675Z :DEBUG: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] [] Abort session to cluster
2025-12-12T11:57:56.576707Z :DEBUG: [local] 0x000071673F74AE10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 Close
2025-12-12T11:57:56.576731Z :DEBUG: [local] 0x000071673F74AE10 TDirectReadSessionManager ServerSessionId=TxUsageTable-DirectRead_WriteToTopic_Demo_25-test-consumer_1_15_5445164154415528771_v1 Close
2025-12-12T11:57:56.576754Z :NOTICE: [local] [local] [a38aa959-202a7656-d988de04-9dd2bc44] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:56.576951Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:56.576957Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:56.576963Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:56.576990Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:56.576994Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|e9c67c6a-60179fd3-529f83d8-85b3ca06_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:56.577189Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:56.577195Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:56.577198Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:56.577321Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:56.577326Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|1d9455f9-862b1f9b-9af06d74-d21409b3_0]  PartitionId [0]  Generation [1] Write session: destroy
