Module: Karafka::Params::Builders::ParamsBatch
- Defined in:
- lib/karafka/params/builders/params_batch.rb
Overview
Builder for creating params batch instances
Class Method Summary collapse
-
.from_kafka_messages(kafka_messages, topic) ⇒ Karafka::Params::ParamsBatch<Karafka::Params::Params>
Creates params batch with params inside based on the incoming messages and the topic from which it comes.
Class Method Details
.from_kafka_messages(kafka_messages, topic) ⇒ Karafka::Params::ParamsBatch<Karafka::Params::Params>
Creates params batch with params inside based on the incoming messages and the topic from which it comes
14 15 16 17 18 19 20 |
# File 'lib/karafka/params/builders/params_batch.rb', line 14 def (, topic) params_array = .map! do || Karafka::Params::Builders::Params.(, topic) end Karafka::Params::ParamsBatch.new(params_array) end |