Contents

module Kafka
  class Message
    attr_reader :value, :key, :topic, :partition

    def initialize(value, key:, topic:, partition:)
      @value = value
      @key = key
      @topic = topic
      @partition = partition
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ruby-kafka-0.1.0.pre.beta1	lib/kafka/message.rb
ruby-kafka-0.1.0.pre.alpha2	lib/kafka/message.rb