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