Function mz_kafka_util::client::get_partitions

source ยท
pub fn get_partitions<C: ClientContext>(
    client: &Client<C>,
    topic: &str,
    timeout: Duration,
) -> Result<Vec<PartitionId>, GetPartitionsError>
Expand description

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