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 



406
407
408
409
410
411
412
413
414
415
 
# 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