in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java [44:54]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
DefaultKafkaDatasetFacet that = (DefaultKafkaDatasetFacet) o;
return Objects.equals(properties, that.properties)
&& Objects.equals(topicIdentifier, that.topicIdentifier);
}