@Override
    public void validate(RowData rowData, RowKind rowKind) throws Exception {
        if (rowData == null) {
            throw new IllegalStateException(String.format(REPLICA_IDENTITY_EXCEPTION, schemaTable));
        }
    }
The {@link RowDataDebeziumDeserializeSchema.ValueValidator} for Postgres connector.
<p>
Copy from com.ververica:flink-connector-postgres-cdc-2.3.0
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/PostgresValueValidator.java