async fn fetch_partition_count(
producer: &ThreadedProducer<TunnelingClientContext<MzClientContext>>,
sink_id: GlobalId,
topic_name: &str,
) -> Result<u64, Error>
Expand description
Fetches the partition count for the identified topic.
async fn fetch_partition_count(
producer: &ThreadedProducer<TunnelingClientContext<MzClientContext>>,
sink_id: GlobalId,
topic_name: &str,
) -> Result<u64, Error>
Fetches the partition count for the identified topic.