class Kafka::Datadog::ConsumerSubscriber

def loop(event)

def loop(event)
  tags = {
    client: event.payload.fetch(:client_id),
    group_id: event.payload.fetch(:group_id),
  }
  histogram("consumer.loop.duration", event.duration, tags: tags)
end

Instance Methods