in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java [154:166]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
TopicPartition partition = (TopicPartition) o;
return partitionId == partition.partitionId
&& topic.equals(partition.topic)
&& ranges.equals(partition.ranges);
}