class Karafka::BaseConsumer

def params_batch=(messages)

Returns:
  • (Karafka::Params::ParamsBatch) - lazy loaded params batch

Parameters:
  • messages (Array, Array) -- messages with raw

Other tags:
    Note: - Until first params usage, it won't parse data at all 
def params_batch=(messages)
  @params_batch = Karafka::Params::ParamsBatch.new(messages, topic.parser)
end