Contents

module Kafka
  class PendingMessage
    attr_reader :value, :key, :topic, :partition, :partition_key

    attr_reader :bytesize, :create_time

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

      @bytesize = key.to_s.bytesize + value.to_s.bytesize
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
ruby-kafka-0.3.8	lib/kafka/pending_message.rb
ruby-kafka-0.3.7	lib/kafka/pending_message.rb
ruby-kafka-0.3.6	lib/kafka/pending_message.rb
ruby-kafka-0.3.5	lib/kafka/pending_message.rb
ruby-kafka-0.3.4	lib/kafka/pending_message.rb
ruby-kafka-0.3.3	lib/kafka/pending_message.rb
ruby-kafka-0.3.2	lib/kafka/pending_message.rb