class Promenade::Kafka::FetcherSubscriber

Public Instance Methods

loop(event) click to toggle source
# File lib/promenade/kafka/fetcher_subscriber.rb, line 12
def loop(event)
  queue_size = event.payload.fetch(:queue_size)
  client = event.payload.fetch(:client_id)
  group_id = event.payload.fetch(:group_id)

  Promenade.metric(:kafka_fetcher_queue_size).set({ client: client, group: group_id }, queue_size)
end