XXXXX AddServerResponse 1 start_direct_read_partition_session_response {
  partition_session_id: 333
}
2025-12-12T11:55:05.165158Z :DEBUG: [db] [client-session-id-1] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:05.165169Z :DEBUG: [db] [client-session-id-1] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:05.165174Z :DEBUG: [db] [client-session-id-1] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:55:05.165267Z :DEBUG: [db] [client-session-id-1] [] Successfully connected. Initializing session
2025-12-12T11:55:05.165409Z :INFO: [db] [client-session-id-1] [] Got InitResponse. ReadSessionId: server-session-id-1
2025-12-12T11:55:05.165431Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:55:05.165451Z :DEBUG: [db] [client-session-id-1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.165567Z :INFO: [db] [client-session-id-1] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "". Partition: 1. Read offset: (NULL)
2025-12-12T11:55:05.165592Z :DEBUG: 0x000050467F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 StartPartitionSession 2 nodeId=3
2025-12-12T11:55:05.165609Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Reconnecting direct read session to node 3 in 0.000000s
2025-12-12T11:55:05.165683Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 AddPartitionSession 2
2025-12-12T11:55:05.165689Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:05.165692Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl bail out 1
XXXXX AddServerResponse 1 init_response {
}
XXXXX AddServerResponse 1 start_direct_read_partition_session_response {
  partition_session_id: 2
}
XXXXX AddServerResponse 1 2025-12-12T11:55:05.165748Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Successfully connected. Initializing session
2025-12-12T11:55:05.165791Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession send message = init_request { session_id: "server-session-id-1" topics_read_settings { path: "TestTopic" } consumer: "TestConsumer" }
direct_read_response {
  partition_session_id: 2
  direct_read_id: 1
  partition_data {
    partition_session_id: 2
    batches {
      message_data {
        created_at {
          nanos: 42000000
        }
        data: "message-0"
        uncompressed_size: 135
      }
      message_data {
        offset: 1
        seq_no: 1
        created_at {
          nanos: 42000000
        }
        data: "message-1"
        uncompressed_size: 135
      }
      producer_id: "producer-id-1"
      codec: 1
      written_at {
        nanos: 42000000
      }
    }
  }
}
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 start_direct_read_partition_session_response {
  partition_session_id: 333
}
2025-12-12T11:55:05.165916Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = start_direct_read_partition_session_response { partition_session_id: 333 }
2025-12-12T11:55:05.166793Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got StartDirectReadPartitionSessionResponse partition_session_id: 333
2025-12-12T11:55:05.166799Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got StartDirectReadPartitionSessionResponse for unknown partition session 333
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 init_response {
}
2025-12-12T11:55:05.166817Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = init_response { }
2025-12-12T11:55:05.167367Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got InitResponse 
2025-12-12T11:55:05.167389Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:55:05.167411Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 2 generation: 4 }
2025-12-12T11:55:05.167418Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 2 generation: 4 }
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 start_direct_read_partition_session_response {
  partition_session_id: 2
}
2025-12-12T11:55:05.167454Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = start_direct_read_partition_session_response { partition_session_id: 2 }
2025-12-12T11:55:05.167459Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got StartDirectReadPartitionSessionResponse partition_session_id: 2
2025-12-12T11:55:05.167463Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got StartDirectReadPartitionSessionResponse for wrong generation (expected 4, got 0) partition_session_id=2
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 direct_read_response {
  partition_session_id: 2
  direct_read_id: 1
  partition_data {
    partition_session_id: 2
    batches {
      message_data {
        created_at {
          nanos: 42000000
        }
        data: "message-0"
        uncompressed_size: 135
      }
      message_data {
        offset: 1
        seq_no: 1
        created_at {
          nanos: 42000000
        }
        data: "message-1"
        uncompressed_size: 135
      }
      producer_id: "producer-id-1"
      codec: 1
      written_at {
        nanos: 42000000
      }
    }
  }
}
2025-12-12T11:55:05.167522Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = DirectReadResponse partitionSessionId = 2 partitionId = 1 directReadId = 1 firstOffset = 0 lastOffset = 1
2025-12-12T11:55:05.167542Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
XXXXX Read 1 
2025-12-12T11:55:05.167569Z :DEBUG: [db] [client-session-id-1] [] Got ReadResponse, serverBytesSize = 0, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.167587Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.167643Z :DEBUG: Decompression task done. Partition/PartitionSessionId: 2 (0-1)
2025-12-12T11:55:05.167656Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.167667Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.167768Z :DEBUG: Take Data. Partition 1. Read: {0, 0} (0-0)
2025-12-12T11:55:05.167780Z :DEBUG: Take Data. Partition 1. Read: {0, 1} (1-1)
2025-12-12T11:55:05.167791Z :DEBUG: [db] [client-session-id-1] [] The application data is transferred to the client. Number of messages 2, size 18 bytes
2025-12-12T11:55:05.167797Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.167802Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.167805Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.167820Z :DEBUG: [db] [client-session-id-1] [] Commit offsets [0, 2). Partition stream id: 1
XXXXX AddServerResponse 1 direct_read_response {
  partition_session_id: 2
  direct_read_id: 2
  partition_data {
    partition_session_id: 2
    batches {
      message_data {
        offset: 2
        seq_no: 2
        created_at {
          nanos: 42000000
        }
        data: "message-2"
        uncompressed_size: 135
      }
      message_data {
        offset: 3
        seq_no: 3
        created_at {
          nanos: 42000000
        }
        data: "message-3"
        uncompressed_size: 135
      }
      producer_id: "producer-id-1"
      codec: 1
      written_at {
        nanos: 42000000
      }
    }
  }
}
XXXXX AddServerResponse 2
XXXXX AddServerResponse 3
2025-12-12T11:55:05.167982Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = DirectReadResponse partitionSessionId = 2 partitionId = 1 directReadId = 2 firstOffset = 2 lastOffset = 3
2025-12-12T11:55:05.167987Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
XXXXX Read 1 
2025-12-12T11:55:05.168006Z :DEBUG: [db] [client-session-id-1] [] Got ReadResponse, serverBytesSize = 0, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168015Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168056Z :DEBUG: Decompression task done. Partition/PartitionSessionId: 2 (2-3)
2025-12-12T11:55:05.168066Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.168070Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168095Z :DEBUG: Take Data. Partition 1. Read: {0, 0} (2-2)
2025-12-12T11:55:05.168101Z :DEBUG: Take Data. Partition 1. Read: {0, 1} (3-3)
2025-12-12T11:55:05.168107Z :DEBUG: [db] [client-session-id-1] [] The application data is transferred to the client. Number of messages 2, size 18 bytes
2025-12-12T11:55:05.168110Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168114Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.168117Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168123Z :DEBUG: [db] [client-session-id-1] [] Commit offsets [2, 4). Partition stream id: 1
XXXXX AddServerResponse 1 direct_read_response {
  partition_session_id: 2
  direct_read_id: 3
  partition_data {
    partition_session_id: 2
    batches {
      message_data {
        offset: 4
        seq_no: 4
        created_at {
          nanos: 42000000
        }
        data: "message-4"
        uncompressed_size: 135
      }
      message_data {
        offset: 5
        seq_no: 5
        created_at {
          nanos: 42000000
        }
        data: "message-5"
        uncompressed_size: 135
      }
      producer_id: "producer-id-1"
      codec: 1
      written_at {
        nanos: 42000000
      }
    }
  }
}
XXXXX AddServerResponse 2
XXXXX AddServerResponse 3
2025-12-12T11:55:05.168204Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = DirectReadResponse partitionSessionId = 2 partitionId = 1 directReadId = 3 firstOffset = 4 lastOffset = 5
2025-12-12T11:55:05.168208Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Waiting for NextDirectReadId=3. Got DirectReadResponse 3
XXXXX Read 1 
2025-12-12T11:55:05.168222Z :DEBUG: [db] [client-session-id-1] [] Got ReadResponse, serverBytesSize = 0, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168228Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168258Z :DEBUG: Decompression task done. Partition/PartitionSessionId: 2 (4-5)
2025-12-12T11:55:05.168286Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.168301Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168325Z :DEBUG: Take Data. Partition 1. Read: {0, 0} (4-4)
2025-12-12T11:55:05.168331Z :DEBUG: Take Data. Partition 1. Read: {0, 1} (5-5)
2025-12-12T11:55:05.168335Z :DEBUG: [db] [client-session-id-1] [] The application data is transferred to the client. Number of messages 2, size 18 bytes
2025-12-12T11:55:05.168339Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168342Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.168345Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168351Z :DEBUG: [db] [client-session-id-1] [] Commit offsets [4, 6). Partition stream id: 1
XXXXX AddServerResponse 1 direct_read_response {
  partition_session_id: 2
  direct_read_id: 4
  partition_data {
    partition_session_id: 2
    batches {
      message_data {
        offset: 6
        seq_no: 6
        created_at {
          nanos: 42000000
        }
        data: "message-6"
        uncompressed_size: 135
      }
      message_data {
        offset: 7
        seq_no: 7
        created_at {
          nanos: 42000000
        }
        data: "message-7"
        uncompressed_size: 135
      }
      producer_id: "producer-id-1"
      codec: 1
      written_at {
        nanos: 42000000
      }
    }
  }
}
XXXXX AddServerResponse 2
XXXXX AddServerResponse 3
2025-12-12T11:55:05.168407Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = DirectReadResponse partitionSessionId = 2 partitionId = 1 directReadId = 4 firstOffset = 6 lastOffset = 7
2025-12-12T11:55:05.168410Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Waiting for NextDirectReadId=4. Got DirectReadResponse 4
XXXXX Read 1 
2025-12-12T11:55:05.168423Z :DEBUG: [db] [client-session-id-1] [] Got ReadResponse, serverBytesSize = 0, now ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168429Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168480Z :DEBUG: Decompression task done. Partition/PartitionSessionId: 2 (6-7)
2025-12-12T11:55:05.168490Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.168494Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168514Z :DEBUG: Take Data. Partition 1. Read: {0, 0} (6-6)
2025-12-12T11:55:05.168518Z :DEBUG: Take Data. Partition 1. Read: {0, 1} (7-7)
2025-12-12T11:55:05.168522Z :DEBUG: [db] [client-session-id-1] [] The application data is transferred to the client. Number of messages 2, size 18 bytes
2025-12-12T11:55:05.168526Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168529Z :DEBUG: [db] [client-session-id-1] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:55:05.168532Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:55:05.168537Z :DEBUG: [db] [client-session-id-1] [] Commit offsets [6, 8). Partition stream id: 1
2025-12-12T11:55:05.168589Z :DEBUG: [db] [client-session-id-1] [] StopPartitionSessionRequest partition_session_id: 2
committed_offset: 8
2025-12-12T11:55:05.168596Z :DEBUG: 0x000050467F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 DeletePartitionSession 2
2025-12-12T11:55:05.168599Z :DEBUG: 0x000050467F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 DeletePartitionSession 2 LockShared
2025-12-12T11:55:05.168603Z :DEBUG: 0x000050467FBC52A0 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 DeletePartitionSession 2
2025-12-12T11:55:05.168607Z :DEBUG: 0x000050467F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 DeletePartitionSession 2 erase
XXXXX Validate
2025-12-12T11:55:05.168668Z :DEBUG: 0x000050467F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 Close
2025-12-12T11:55:05.168671Z :DEBUG: 0x000050467F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 Close
