class Kafka::Datadog::FetcherSubscriber

Public Instance Methods

loop(event) click to toggle source
# File lib/kafka/datadog.rb, line 406
def loop(event)
  queue_size = event.payload.fetch(:queue_size)

  tags = {
    client: event.payload.fetch(:client_id),
    group_id: event.payload.fetch(:group_id),
  }

  gauge("fetcher.queue_size", queue_size, tags: tags)
end