class Karafka::Params::ParamsBatch

def initialize(messages_batch, topic_parser)

Parameters:
  • topic_parser (Class) -- topic parser for unparsing messages values
  • messages_batch (Array) -- messages batch 
def initialize(messages_batch, topic_parser)
  @params_batch = messages_batch.map! do |message|
    Karafka::Params::Params.build(message, topic_parser)
  end
end