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

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

Parameters:

  • kafka_messages (Array<Kafka::FetchedMessage>) —

    raw fetched messages

  • topic (Karafka::Routing::Topic) —

    topic for which we’re received messages

Returns:



14
15
16
17
18
19
20
 
# 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