Module: Karafka::Messages::Builders::Messages

Defined in:

lib/karafka/messages/builders/messages.rb

Overview

Builder for creating message batch instances.

Class Method Summary

• .call(messages, topic, received_at) ⇒ Karafka::Messages::Messages

  Creates messages batch with messages inside based on the incoming messages and the topic from which it comes.

Class Method Details

.call(messages, topic, received_at) ⇒ Karafka::Messages::Messages

Creates messages batch with messages inside based on the incoming messages and the topic from which it comes.

Parameters:

• messages (Array<Karafka::Messages::Message>) —

  karafka messages array

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

  topic for which we’re received messages

• received_at (Time) —

  moment in time when the messages were received

Returns:

• (Karafka::Messages::Messages) —

  messages batch object

# File 'lib/karafka/messages/builders/messages.rb', line 16

def call(messages, topic, received_at)
  # We cannot freeze the batch metadata because it is altered with the processed_at time
  # prior to the consumption. It is being frozen there
  metadata = BatchMetadata.call(
    messages,
    topic,
    received_at
  )

  Karafka::Messages::Messages.new(
    messages,
    metadata
  ).freeze
end