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