code: 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
docs: 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