Function kafka_util::client::get_partitions [−][src]
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