This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit cad62c4d054ee6b294f26ef4192d167d886db72d Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Oct 14 11:45:42 2020 +0200 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs --- .../{SQSKeySetterTransformers.java => SQSKeySetterTransforms.java} | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java similarity index 95% rename from connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java rename to connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java index 7da0da4..1a14c46 100644 --- a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java +++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java @@ -24,7 +24,7 @@ import org.apache.kafka.connect.data.Schema; import org.apache.kafka.connect.header.Headers; import org.apache.kafka.connect.transforms.Transformation; -public class SQSKeySetterTransformers<R extends ConnectRecord<R>> implements Transformation<R> { +public class SQSKeySetterTransforms<R extends ConnectRecord<R>> implements Transformation<R> { public static final ConfigDef CONFIG_DEF = new ConfigDef() .define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM, "Fetch the Camel.CamelAwsSqsMessageId header and set it as the key for the kafka record");
