in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java [17:28]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
TopicPartitionOffset that = (TopicPartitionOffset) o;
return partition == that.partition
&& offset == that.offset
&& Objects.equals(topic, that.topic);
}