Function mz_kafka_util::client::get_partitions

source · 
pub fn get_partitions<C: ClientContext>(
    client: &Client<C>,
    topic: &str,
    timeout: Duration
) -> Result<Vec<i32>, Error>
Expand description

Retrieve number of partitions for a given topic using the given client