Contents

module Karafka
  # Namespace that encapsulates everything related to connections
  module Connection
    # Single incoming Kafka message instance wrapper
    class Message
      attr_reader :topic, :content

      # @param topic [String] topic from which this message comes
      # @param content [String] raw message content (not deserialized or anything) from Kafka
      # @return [Karafka::Connection::Message] incoming message instance
      def initialize(topic, content)
        @topic = topic
        @content = content
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
karafka-0.5.0.3	lib/karafka/connection/message.rb
karafka-0.5.0.2	lib/karafka/connection/message.rb
karafka-0.5.0.1	lib/karafka/connection/message.rb
karafka-0.5.0	lib/karafka/connection/message.rb