connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/RecordValidator.java [78:88]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    static RecordValidator requiresValue(DorisSinkConfig config) {
        return record -> {
            Schema valueSchema = record.getSchema();
            if (record.getData() != null
                    && valueSchema != null
                    && valueSchema.getFieldType() == FieldType.STRUCT) {
                return;
            }
            throw new ConnectException(record.toString());
        };
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java [60:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    static RecordValidator requiresValue(JdbcSinkConfig config) {
        return record -> {
            Schema valueSchema = record.getSchema();
            if (record.getData() != null
                    && valueSchema != null
                    && valueSchema.getFieldType() == FieldType.STRUCT) {
                return;
            }
            throw new ConnectException(record.toString());
        };
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -