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