Function mz_storage::source::kafka::fetch_partition_info

fn fetch_partition_info<C: ClientContext>(
    client: &Client<C>,
    topic: &str,
    fetch_timeout: Duration
) -> Result<BTreeMap<PartitionId, WatermarkOffsets>, Error>

Fetches the list of partitions and their corresponding high watermark