in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java [65:74]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
SinkBufferFlushMode that = (SinkBufferFlushMode) o;
return batchSize == that.batchSize && batchIntervalMs == that.batchIntervalMs;
}