module Karafka::Extensions::StdoutListener

Additional methods for listener that listen on instrumentation related to the Sidekiq backend of Karafka

Public Instance Methods

on_backends_sidekiq_base_worker_perform(event) click to toggle source

Logs ino about processing certain events with a given Sidekiq worker @param event [Dry::Events::Event] event details including payload

# File lib/karafka/extensions/stdout_listener.rb, line 19
def on_backends_sidekiq_base_worker_perform(event)
  count = event[:consumer].send(:params_batch).size
  topic = event[:consumer].topic.name
  time = event[:time]
  info "Sidekiq processing of topic #{topic} with #{count} messages took #{time} ms"
end
on_backends_sidekiq_process(event) click to toggle source

Logs info about scheduling of a certain dataset with a Sidekiq backend @param event [Dry::Events::Event] event details including payload

# File lib/karafka/extensions/stdout_listener.rb, line 10
def on_backends_sidekiq_process(event)
  count = event[:caller].send(:params_batch).size
  topic = event[:caller].topic.name
  time = event[:time]
  info "Scheduling of #{count} messages to Sidekiq on topic #{topic} took #{time} ms"
end