lib/karafka/base_worker.rb
def perform(topic_id, params_batch, metadata)
      consumer = consumer(topic_id, params_batch, metadata)

      Karafka.monitor.instrument(
        'backends.sidekiq.base_worker.perform',
        caller: self,
        consumer: consumer
      ) { consumer.consume }
    end
def perform(topic_id, params_batch, metadata)
      consumer = consumer(topic_id, params_batch, metadata)

      Karafka.monitor.instrument(
        'backends.sidekiq.base_worker.perform',
        caller: self,
        consumer: consumer
      ) { consumer.consume }
    end
Executes the logic that lies in #perform Karafka consumer method
 @param topic_id [String] Unique topic id that we will use to find a proper topic
 @param params_batch [Array<Hash>] Array with messages batch
 @param metadata [Hash, nil] hash with all the metadata or nil if not present