lib/karafka/base_worker.rb in karafka-sidekiq-backend-1.2.0.beta2 vs lib/karafka/base_worker.rb in karafka-sidekiq-backend-1.2.0.beta3

@@ -23,10 +23,10 @@
     # @return [Karafka::Consumer] descendant of Karafka::BaseConsumer that matches the topic
     #   with params_batch assigned already (consumer is ready to use)
     def consumer(topic_id, params_batch)
       topic = Karafka::Routing::Router.find(topic_id)
       consumer = topic.consumer.new
-      consumer.params_batch = topic.interchanger.parse(params_batch)
+      consumer.params_batch = topic.interchanger.decode(params_batch)
       consumer
     end
   end
 end