Class: Promenade::Kafka::FetcherSubscriber

Inherits:
Subscriber
  • Object
show all
Defined in:
lib/promenade/kafka/fetcher_subscriber.rb

Instance Method Summary collapse

Instance Method Details

#loop(event) ⇒ Object 



12
13
14
15
16
17
18
 
# 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