in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java [135:154]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
if (!super.equals(o)) {
return false;
}
SinkConfiguration that = (SinkConfiguration) o;
return transactionTimeoutMillis == that.transactionTimeoutMillis
&& topicMetadataRefreshInterval == that.topicMetadataRefreshInterval
&& partitionSwitchSize == that.partitionSwitchSize
&& enableSchemaEvolution == that.enableSchemaEvolution
&& messageKeyHash == that.messageKeyHash
&& maxRecommitTimes == that.maxRecommitTimes
&& enableMetrics == that.enableMetrics
&& validateSinkMessageBytes == that.validateSinkMessageBytes;
}