private boolean isStartScnInArchiveLogs(Scn startScn) throws SQLException {
        List<LogFile> logs =
                LogMinerHelper.getLogFilesForOffsetScn(
                        jdbcConnection,
                        startScn,
                        archiveLogRetention,
                        archiveLogOnlyMode,
                        archiveDestinationName);
        return logs.stream()
                .anyMatch(
                        l -> l.getFirstScn().compareTo(startScn) <= 0
                                && l.getNextScn().compareTo(startScn) > 0
                                && l.getType().equals(LogFile.Type.ARCHIVE));
    }
Returns whether the starting system change number is in the archive logs.

@param startScn the starting system change number
@return true if the starting system change number is in the archive logs; false otherwise.
@throws SQLException if a database exception occurred
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java