class Kafka::PendingMessage

Attributes

bytesize[R]
create_time[R]
headers[R]
key[R]
partition[R]
partition_key[R]
topic[R]
value[R]

Public Class Methods

new(value:, key:, headers: {}, topic:, partition:, partition_key:, create_time:) click to toggle source
# File lib/kafka/pending_message.rb, line 7
def initialize(value:, key:, headers: {}, topic:, partition:, partition_key:, create_time:)
  @value = value
  @key = key
  @headers = headers
  @topic = topic
  @partition = partition
  @partition_key = partition_key
  @create_time = create_time
  @bytesize = key.to_s.bytesize + value.to_s.bytesize
end

Public Instance Methods

==(other) click to toggle source
# File lib/kafka/pending_message.rb, line 18
def ==(other)
  @value == other.value &&
    @key == other.key &&
    @topic == other.topic &&
    @headers == other.headers &&
    @partition == other.partition &&
    @partition_key == other.partition_key &&
    @create_time == other.create_time &&
    @bytesize == other.bytesize
end