async fn progresses(
        &self,
        partitions: Vec<KafkaPartition>,
    ) -> BTreeMap<KafkaPartition, SequencerProgress> {
        self.data.progresses(partitions).await
    }
/// Return the ingestion progress from each sequencer
Return the ingestion progress from each sequencer
Return the ingestion progress from each sequencer
async fn progresses(
        &self,
        partitions: Vec<KafkaPartition>,
    ) -> BTreeMap<KafkaPartition, SequencerProgress> {
        self.data.progresses(partitions).await
    }
async fn progresses ( & self , partitions : Vec < KafkaPartition > , ) -> BTreeMap < KafkaPartition , SequencerProgress > { self . data . progresses ( partitions ) . await }
Return the ingestion progress from each sequencer
Return the ingestion progress from each sequencer
&self
partitions
Vec<KafkaPartition>
&self
partitions
Vec<KafkaPartition>