module Karafka::Params::Builders::ParamsBatch

Builder for creating params batch instances

Public Class Methods

from_kafka_messages(kafka_messages, topic) click to toggle source

Creates params batch with params inside based on the incoming messages and the topic from which it comes @param kafka_messages [Array<Kafka::FetchedMessage>] raw fetched messages @param topic [Karafka::Routing::Topic] topic for which we're received messages @return [Karafka::Params::ParamsBatch<Karafka::Params::Params>] batch with params

# File lib/karafka/params/builders/params_batch.rb, line 14
def from_kafka_messages(kafka_messages, topic)
  params_array = kafka_messages.map do |message|
    Karafka::Params::Builders::Params.from_kafka_message(message, topic)
  end

  Karafka::Params::ParamsBatch.new(params_array).freeze
end