in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSource.java [134:146]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
KinesisDynamicSource that = (KinesisDynamicSource) o;
return Objects.equals(physicalDataType, that.physicalDataType) &&
Objects.equals(stream, that.stream) &&
Objects.equals(consumerProperties, that.consumerProperties) &&
Objects.equals(decodingFormat, that.decodingFormat);
}