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 



386
387
388
389
390
391
392
393
394
395
 
# File 'lib/kafka/datadog.rb', line 386

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