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