lib/karafka/consumers/single_params.rb in karafka-1.3.6 vs lib/karafka/consumers/single_params.rb in karafka-1.3.7
- old
+ new
@@ -6,10 +6,10 @@
module SingleParams
private
# @return [Karafka::Params::Params] params instance for non batch consumption consumers
def params
- params_batch.first
+ params_batch.to_a.first
end
end
end
end