mz_storage::sink::kafka

Function 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.