Function mz_storage::sink::kafka::fetch_partition_count

source ยท 
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.