Class: Karafka::Connection::Message

Inherits:

Object

• Object
• Karafka::Connection::Message

Defined in:

lib/karafka/connection/message.rb

Overview

Single incoming Kafka message instance wrapper

Instance Attribute Summary

• #content ⇒ Object readonly

  Returns the value of attribute content.

• #topic ⇒ Object readonly

  Returns the value of attribute topic.

Instance Method Summary

• #initialize(topic, content) ⇒ Karafka::Connection::Message constructor

  Incoming message instance.

Constructor Details

#initialize(topic, content) ⇒ Karafka::Connection::Message

Returns incoming message instance.

Parameters:

• topic (String) —

  topic from which this message comes

• content (String) —

  raw message content (not deserialized or anything) from Kafka

# File 'lib/karafka/connection/message.rb', line 11

def initialize(topic, content)
  @topic = topic
  @content = content
end

Instance Attribute Details

#content ⇒ Object (readonly)

Returns the value of attribute content.

# File 'lib/karafka/connection/message.rb', line 6

def content
  @content
end

#topic ⇒ Object (readonly)

Returns the value of attribute topic.

# File 'lib/karafka/connection/message.rb', line 6

def topic
  @topic
end