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