Class: Kafka::Datadog::FetcherSubscriber

Inherits:
StatsdSubscriber
  • Object
show all
Defined in:
lib/kafka/datadog.rb

Instance Method Summary collapse

Instance Method Details

#loop(event) ⇒ Object 



378
379
380
381
382
383
384
385
386
387
 
# File 'lib/kafka/datadog.rb', line 378

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