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