Function mz_storage::source::kafka::fetch_partition_info

source ยท 
fn fetch_partition_info<C: ConsumerContext>(
    consumer: &BaseConsumer<C>,
    topic: &str,
    fetch_timeout: Duration,
) -> Result<BTreeMap<PartitionId, u64>, Error>
Expand description

Fetches the list of partitions and their corresponding high watermark.