module Kafka::Prometheus
Constants
- DELAY_BUCKETS
- LATENCY_BUCKETS
- SIZE_BUCKETS
Attributes
registry[RW]
Public Class Methods
start(registry = ::Prometheus::Client.registry)
click to toggle source
# File lib/kafka/prometheus.rb, line 32 def start(registry = ::Prometheus::Client.registry) @registry = registry ConnectionSubscriber.attach_to 'connection.kafka' ConsumerSubscriber.attach_to 'consumer.kafka' ProducerSubscriber.attach_to 'producer.kafka' AsyncProducerSubscriber.attach_to 'async_producer.kafka' FetcherSubscriber.attach_to 'fetcher.kafka' end