connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/KafkaConnectAdaptorSink.java [42:54]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    protected SinkRecord transforms(SinkRecord record) {
        List<Transformation> transformations = transformationWrapper.transformations();
        Iterator transformationIterator = transformations.iterator();
        while (transformationIterator.hasNext()) {
            Transformation<SinkRecord> transformation = (Transformation) transformationIterator.next();
            log.trace("applying transformation {} to {}", transformation.getClass().getName(), record);
            record = transformation.apply(record);
            if (record == null) {
                break;
            }
        }
        return record;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/KafkaConnectAdaptorSource.java [43:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    protected SourceRecord transforms(SourceRecord record) {
        List<Transformation> transformations = transformationWrapper.transformations();
        Iterator transformationIterator = transformations.iterator();
        while (transformationIterator.hasNext()) {
            Transformation<SourceRecord> transformation = (Transformation) transformationIterator.next();
            log.trace("applying transformation {} to {}", transformation.getClass().getName(), record);
            record = transformation.apply(record);
            if (record == null) {
                break;
            }
        }
        return record;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -