Function mz_storage::source::kafka::get_kafka_partitions

fn get_kafka_partitions<C>(
    consumer: &BaseConsumer<C>,
    topic: &str,
    timeout: Duration
) -> Result<Vec<i32>, Error>where
    C: ConsumerContext,

Return the list of partition ids associated with a specific topic