Method: Kafka::PendingMessage#==

Defined in:
lib/kafka/pending_message.rb

#==(other) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
 
# 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