Method: Kafka::Prometheus.start

Defined in:
lib/kafka/prometheus.rb

.start(registry = ::Prometheus::Client.registry) ⇒ Object 



32
33
34
35
36
37
38
39
 
# 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