Function coord::timestamp::get_kafka_partitions

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

Return the list of partition ids associated with a specific topic