public static PostgresSchema refreshSchema(
            PostgresSchema schema,
            PostgresConnection pgConnection,
            boolean printReplicaIdentityInfo)
            throws SQLException {
        return schema.refresh(pgConnection, printReplicaIdentityInfo);
    }
A utility class for accessing various Debezium package-private methods.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/io/debezium/connector/postgresql/Utils.java