Function mz_storage::sink::kafka::fetch_partition_count_loop

source ยท 
async fn fetch_partition_count_loop<F>(
    producer: ThreadedProducer<TunnelingClientContext<MzClientContext>>,
    sink_id: GlobalId,
    topic_name: String,
    interval: Duration,
    update_partition_count: Arc<F>,
)
where
    F: Fn(u64),
Expand description

Fetches the partition count for the identified topic at the specified interval.

When an updated partition count is discovered, invokes update_partition_count with the new partition count.