lib/karafka/base_worker.rb in karafka-sidekiq-backend-1.3.1 vs lib/karafka/base_worker.rb in karafka-sidekiq-backend-1.4.0

@@ -52,10 +52,10 @@
         topic.interchanger.decode(params_batch),
         topic
       )
 
       if topic.batch_fetching
-        consumer.metadata = Params::Builders::Metadata.from_hash(
+        consumer.batch_metadata = Params::Builders::BatchMetadata.from_hash(
           metadata,
           topic
         )
       end