class Kafka::PendingMessage

def ==(other)
  @value == other.value &&
    @key == other.key &&
    @topic == other.topic &&
    @partition == other.partition &&
    @partition_key == other.partition_key &&
    @create_time == other.create_time &&
    @bytesize == other.bytesize
end

def initialize(value, key, topic, partition, partition_key, create_time)
  @value = value
  @key = key
  @topic = topic
  @partition = partition
  @partition_key = partition_key
  @create_time = create_time
  @bytesize = key.to_s.bytesize + value.to_s.bytesize
end