def METHOD_NAME(self, batch: List[AirbyteRecordMessage]):
    documents: List[Document] = []
    ids_to_delete = []
    for record in batch:
        record_documents, record_id_to_delete = self.processor.process(record)
        documents.extend(record_documents)
        if record_id_to_delete is not None:
            ids_to_delete.append(record_id_to_delete)
    self.indexer.index(documents, ids_to_delete)