async fn collect_statistics(
receiver: Receiver<Statistics>,
metrics: Arc<KafkaSinkMetrics>,
)
Expand description
Listens for statistics updates from librdkafka and updates our Prometheus metrics.
async fn collect_statistics(
receiver: Receiver<Statistics>,
metrics: Arc<KafkaSinkMetrics>,
)
Listens for statistics updates from librdkafka and updates our Prometheus metrics.