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
pub fn get_partitions<C: ClientContext>(
client: &Client<C>,
topic: &str,
timeout: Duration,
) -> Result<Vec<PartitionId>, GetPartitionsError>
Retrieve number of partitions for a given topic
using the given client