Class: Promenade::Karafka::StatisticsSubscriber

Inherits:

Subscriber

• Object
• ActiveSupport::Subscriber
• Subscriber
• Promenade::Karafka::StatisticsSubscriber

Defined in:

lib/promenade/karafka/statistics_subscriber.rb

Instance Method Summary

• #emitted(event) ⇒ Object

Instance Method Details

#emitted(event) ⇒ Object

# File 'lib/promenade/karafka/statistics_subscriber.rb', line 22

def emitted(event)
  group = event.payload[:consumer_group_id]
  statistics = event.payload[:statistics].with_indifferent_access
  client_id = statistics[:client_id]

  report_topic_metrics(statistics[:topics], group, client_id)
  report_connection_metrics(statistics[:brokers], client_id)
end