public static boolean isCompatible(Collection<SchemaRecord> records) {
        for (SchemaRecord record : records) {
            // check the source/position/ddl is not null
            if (!record.isHistoryRecord()) {
                return false;
            } else {
                break;
            }
        }
        return true;
    }
Determine whether the {@link FlinkDatabaseHistory} is compatible with the specified state.
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/internal/FlinkDatabaseHistory.java