in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java [133:158]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
DispatcherMessage that = (DispatcherMessage) o;
return partition == that.partition
&& offset == that.offset
&& stub == that.stub
&& retryCount == that.retryCount
&& dispatchAttempt == that.dispatchAttempt
&& timeoutCount == that.timeoutCount
&& type == that.type
&& destination.equals(that.destination)
&& Arrays.equals(key, that.key)
&& Arrays.equals(value, that.value)
&& headers.equals(that.headers)
&& group.equals(that.group)
&& topic.equals(that.topic)
&& physicalTopic.equals(that.physicalTopic)
&& physicalCluster.equals(that.physicalCluster)
&& physicalPartition == that.physicalPartition
&& physicalOffset == that.physicalOffset;
}