Function mz_storage::sink::kafka::collect_statistics

source ยท 
async fn collect_statistics(
    receiver: Receiver<Statistics>,
    metrics: Arc<KafkaSinkMetrics>,
)
Expand description

Listens for statistics updates from librdkafka and updates our Prometheus metrics.