fn fetch_partition_info<C: ConsumerContext>(
consumer: &BaseConsumer<C>,
topic: &str,
fetch_timeout: Duration,
) -> Result<BTreeMap<PartitionId, u64>, GetPartitionsError>Expand description
Fetches the list of partitions and their corresponding high watermark.