class Poseidon::MessageToSend

A message we want to send to Kafka. Comprised of the topic we want to send it to, the body of the message and an optional key.

mts = Poseidon::MessageToSend.new("topic", "value", "opt_key")

@api public

Attributes

key[R]
topic[R]
value[R]

Public Class Methods

new(topic, value, key = nil) click to toggle source

Create a new message for sending to a Kafka broker.

@param [String] topic

Topic this message should be sent to.

@param [String] value

Value of the message we want to send.

@param [String] key

Optional. Message's key, used to route a message
to a specific broker.  Otherwise, messages will be
sent to brokers in a round-robin manner.

@api public

# File lib/poseidon/message_to_send.rb, line 26
def initialize(topic, value, key = nil)
  raise ArgumentError, "Must provide a non-nil topic" if topic.nil?
  @topic  = topic
  @value  = value
  @key    = key
end