class Kafka::Statsd::FetcherSubscriber

Public Instance Methods

loop(event) click to toggle source
# File lib/kafka/statsd.rb, line 285
def loop(event)
  queue_size = event.payload.fetch(:queue_size)
  client = event.payload.fetch(:client_id)
  group_id = event.payload.fetch(:group_id)

  gauge("fetcher.#{client}.#{group_id}.queue_size", queue_size)
end