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