You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/02/28 13:51:14 UTC
[camel] 04/11: CAMEL-13165 - Added camel-aws-msk to kit
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.git
commit 4925b585df05fe23d1e45b50ac90195386cf4f6e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Feb 28 13:16:25 2019 +0100
CAMEL-13165 - Added camel-aws-msk to kit
---
apache-camel/pom.xml | 10 ++
apache-camel/src/main/descriptors/common-bin.xml | 2 +
bom/camel-bom/pom.xml | 10 ++
components/camel-aws-msk/bin/pom.xml | 81 ---------
.../bin/src/main/docs/aws-kms-component.adoc | 182 ---------------------
.../camel/component/aws/kms/MSKComponent.class | Bin 6580 -> 0 bytes
.../aws/kms/MSKComponentVerifierExtension.class | Bin 5686 -> 0 bytes
.../camel/component/aws/kms/MSKConfiguration.class | Bin 5398 -> 0 bytes
.../camel/component/aws/kms/MSKConstants.class | Bin 799 -> 0 bytes
.../camel/component/aws/kms/MSKEndpoint.class | Bin 8731 -> 0 bytes
.../camel/component/aws/kms/MSKOperations.class | Bin 1146 -> 0 bytes
.../camel/component/aws/kms/MSKProducer.class | Bin 5348 -> 0 bytes
.../component/aws/kms/AmazonMKSClientMock.class | Bin 775 -> 0 bytes
.../component/aws/kms/KMSProducerSpringTest.class | Bin 9622 -> 0 bytes
.../camel/component/aws/kms/KMSProducerTest.class | Bin 9526 -> 0 bytes
.../aws/kms/MSKComponentConfigurationTest.class | Bin 2491 -> 0 bytes
.../kms/MSKComponentVerifierExtensionTest.class | Bin 3883 -> 0 bytes
.../bin/src/test/resources/log4j2.properties | 28 ----
.../aws/kms/KMSComponentSpringTest-context.xml | 60 -------
components/pom.xml | 1 +
parent/pom.xml | 10 ++
.../camel-spring-boot-dependencies/pom.xml | 10 ++
22 files changed, 43 insertions(+), 351 deletions(-)
diff --git a/apache-camel/pom.xml b/apache-camel/pom.xml
index 3932df5..282838d 100644
--- a/apache-camel/pom.xml
+++ b/apache-camel/pom.xml
@@ -195,6 +195,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-mq</artifactId>
<version>${project.version}</version>
</dependency>
@@ -1674,6 +1679,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-mq-starter</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/apache-camel/src/main/descriptors/common-bin.xml b/apache-camel/src/main/descriptors/common-bin.xml
index a3beabf..ca7b3cf 100644
--- a/apache-camel/src/main/descriptors/common-bin.xml
+++ b/apache-camel/src/main/descriptors/common-bin.xml
@@ -61,6 +61,7 @@
<include>org.apache.camel:camel-aws-kms</include>
<include>org.apache.camel:camel-aws-lambda</include>
<include>org.apache.camel:camel-aws-mq</include>
+ <include>org.apache.camel:camel-aws-msk</include>
<include>org.apache.camel:camel-aws-s3</include>
<include>org.apache.camel:camel-aws-sdb</include>
<include>org.apache.camel:camel-aws-ses</include>
@@ -393,6 +394,7 @@
<include>org.apache.camel:camel-aws-kms-starter</include>
<include>org.apache.camel:camel-aws-lambda-starter</include>
<include>org.apache.camel:camel-aws-mq-starter</include>
+ <include>org.apache.camel:camel-aws-msk-starter</include>
<include>org.apache.camel:camel-aws-s3-starter</include>
<include>org.apache.camel:camel-aws-sdb-starter</include>
<include>org.apache.camel:camel-aws-ses-starter</include>
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index f5bf6bf..9e86d37 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -283,6 +283,16 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/components/camel-aws-msk/bin/pom.xml b/components/camel-aws-msk/bin/pom.xml
deleted file mode 100644
index c29ca1d..0000000
--- a/components/camel-aws-msk/bin/pom.xml
+++ /dev/null
@@ -1,81 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>components</artifactId>
- <version>3.0.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-aws-msk</artifactId>
- <packaging>jar</packaging>
-
- <name>Camel :: AWS MSK</name>
- <description>A Camel Amazon MSK Web Service Component</description>
-
- <properties>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
- <dependency>
- <groupId>com.amazonaws</groupId>
- <artifactId>aws-java-sdk-kafka</artifactId>
- <version>${aws-java-sdk-version}</version>
- </dependency>
-
- <!-- for testing -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-spring</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-api</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <scope>test</scope>
- </dependency>
- </dependencies>
-</project>
diff --git a/components/camel-aws-msk/bin/src/main/docs/aws-kms-component.adoc b/components/camel-aws-msk/bin/src/main/docs/aws-kms-component.adoc
deleted file mode 100644
index 77f8a26..0000000
--- a/components/camel-aws-msk/bin/src/main/docs/aws-kms-component.adoc
+++ /dev/null
@@ -1,182 +0,0 @@
-[[aws-kms-component]]
-== AWS KMS Component
-
-*Available as of Camel version 2.21*
-
-The KMS component supports create, run, start, stop and terminate
-https://aws.amazon.com/it/kms/[AWS KMS] instances.
-
-Prerequisites
-
-You must have a valid Amazon Web Services developer account, and be
-signed up to use Amazon KMS. More information are available at
-https://aws.amazon.com/it/mq/[Amazon KMS].
-
-### URI Format
-
-[source,java]
--------------------------
-aws-kms://label[?options]
--------------------------
-
-You can append query options to the URI in the following format,
-?options=value&option2=value&...
-
-### URI Options
-
-
-// component options: START
-The AWS KMS component supports 5 options, which are listed below.
-
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *configuration* (advanced) | The AWS KMS default configuration | | KMSConfiguration
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-| *region* (producer) | The region in which KMS client needs to work | | String
-| *resolveProperty Placeholders* (advanced) | Whether the component should resolve property placeholders on itself when starting. Only properties which are of String type can use property placeholders. | true | boolean
-|===
-// component options: END
-
-
-
-
-// endpoint options: START
-The AWS KMS endpoint is configured using URI syntax:
-
-----
-aws-kms:label
-----
-
-with the following path and query parameters:
-
-==== Path Parameters (1 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *label* | *Required* Logical name | | String
-|===
-
-
-==== Query Parameters (8 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *kmsClient* (producer) | To use a existing configured AWS KMS as client | | AWSKMS
-| *operation* (producer) | *Required* The operation to perform | | KMSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the KMS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the KMS client | | Integer
-| *region* (producer) | The region in which KMS client needs to work | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-|===
-// endpoint options: END
-// spring-boot-auto-configure options: START
-=== Spring Boot Auto-Configuration
-
-When using Spring Boot make sure to use the following Maven dependency to have support for auto configuration:
-
-[source,xml]
-----
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-kms-starter</artifactId>
- <version>x.x.x</version>
- <!-- use the same version as your Camel core version -->
-</dependency>
-----
-
-
-The component supports 12 options, which are listed below.
-
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *camel.component.aws-kms.access-key* | Amazon AWS Access Key | | String
-| *camel.component.aws-kms.configuration.access-key* | Amazon AWS Access Key | | String
-| *camel.component.aws-kms.configuration.kms-client* | To use a existing configured AWS KMS as client | | AWSKMS
-| *camel.component.aws-kms.configuration.operation* | The operation to perform | | KMSOperations
-| *camel.component.aws-kms.configuration.proxy-host* | To define a proxy host when instantiating the KMS client | | String
-| *camel.component.aws-kms.configuration.proxy-port* | To define a proxy port when instantiating the KMS client | | Integer
-| *camel.component.aws-kms.configuration.region* | The region in which KMS client needs to work | | String
-| *camel.component.aws-kms.configuration.secret-key* | Amazon AWS Secret Key | | String
-| *camel.component.aws-kms.enabled* | Whether to enable auto configuration of the aws-kms component. This is enabled by default. | | Boolean
-| *camel.component.aws-kms.region* | The region in which KMS client needs to work | | String
-| *camel.component.aws-kms.resolve-property-placeholders* | Whether the component should resolve property placeholders on itself when starting. Only properties which are of String type can use property placeholders. | true | Boolean
-| *camel.component.aws-kms.secret-key* | Amazon AWS Secret Key | | String
-|===
-// spring-boot-auto-configure options: END
-
-
-
-
-Required KMS component options
-
-You have to provide the amazonKmsClient in the
-Registry or your accessKey and secretKey to access
-the https://aws.amazon.com/it/kms/[Amazon KMS] service.
-
-### Usage
-
-#### Message headers evaluated by the MQ producer
-
-[width="100%",cols="10%,10%,80%",options="header",]
-|=======================================================================
-|Header |Type |Description
-
-|`CamelAwsKMSLimit` |`Integer` |The limit number of keys to return while performing a listKeys operation
-
-|`CamelAwsKMSOperation` |`String` |The operation we want to perform
-
-|`CamelAwsKMSDescription` |`String` |A key description to use while performing a createKey operation
-
-|`CamelAwsKMSKeyId` |`String` |The key Id
-|=======================================================================
-
-#### KMS Producer operations
-
-Camel-AWS KMS component provides the following operation on the producer side:
-
-- listKeys
-- createKey
-- disableKey
-- scheduleKeyDeletion
-- describeKey
-- enableKey
-
-Dependencies
-
-Maven users will need to add the following dependency to their pom.xml.
-
-*pom.xml*
-
-[source,xml]
----------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-kms</artifactId>
- <version>${camel-version}</version>
-</dependency>
----------------------------------------
-
-where `${camel-version`} must be replaced by the actual version of Camel
-(2.16 or higher).
-
-### See Also
-
-* Configuring Camel
-* Component
-* Endpoint
-* Getting Started
-
-* AWS Component
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKComponent.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKComponent.class
deleted file mode 100644
index c7d4963..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKComponent.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKComponentVerifierExtension.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKComponentVerifierExtension.class
deleted file mode 100644
index 144ae2e..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKComponentVerifierExtension.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKConfiguration.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKConfiguration.class
deleted file mode 100644
index dbf1478..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKConfiguration.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKConstants.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKConstants.class
deleted file mode 100644
index fb77aaf..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKConstants.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKEndpoint.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKEndpoint.class
deleted file mode 100644
index 7fd6129..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKEndpoint.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKOperations.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKOperations.class
deleted file mode 100644
index 16ec708..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKOperations.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKProducer.class b/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKProducer.class
deleted file mode 100644
index 6c8b42e..0000000
Binary files a/components/camel-aws-msk/bin/src/main/java/org/apache/camel/component/aws/kms/MSKProducer.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/AmazonMKSClientMock.class b/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/AmazonMKSClientMock.class
deleted file mode 100644
index 2a5517c..0000000
Binary files a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/AmazonMKSClientMock.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/KMSProducerSpringTest.class b/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/KMSProducerSpringTest.class
deleted file mode 100644
index 5a6a3fe..0000000
Binary files a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/KMSProducerSpringTest.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/KMSProducerTest.class b/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/KMSProducerTest.class
deleted file mode 100644
index 50605ab..0000000
Binary files a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/KMSProducerTest.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/MSKComponentConfigurationTest.class b/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/MSKComponentConfigurationTest.class
deleted file mode 100644
index 0e6e223..0000000
Binary files a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/MSKComponentConfigurationTest.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/MSKComponentVerifierExtensionTest.class b/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/MSKComponentVerifierExtensionTest.class
deleted file mode 100644
index e161b81..0000000
Binary files a/components/camel-aws-msk/bin/src/test/java/org/apache/camel/component/aws/kms/MSKComponentVerifierExtensionTest.class and /dev/null differ
diff --git a/components/camel-aws-msk/bin/src/test/resources/log4j2.properties b/components/camel-aws-msk/bin/src/test/resources/log4j2.properties
deleted file mode 100644
index 986f470..0000000
--- a/components/camel-aws-msk/bin/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-## ---------------------------------------------------------------------------
-## Licensed to the Apache Software Foundation (ASF) under one or more
-## contributor license agreements. See the NOTICE file distributed with
-## this work for additional information regarding copyright ownership.
-## The ASF licenses this file to You under the Apache License, Version 2.0
-## (the "License"); you may not use this file except in compliance with
-## the License. You may obtain a copy of the License at
-##
-## http://www.apache.org/licenses/LICENSE-2.0
-##
-## Unless required by applicable law or agreed to in writing, software
-## distributed under the License is distributed on an "AS IS" BASIS,
-## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-## See the License for the specific language governing permissions and
-## limitations under the License.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-aws-kms-test.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.file.ref = file
diff --git a/components/camel-aws-msk/bin/src/test/resources/org/apache/camel/component/aws/kms/KMSComponentSpringTest-context.xml b/components/camel-aws-msk/bin/src/test/resources/org/apache/camel/component/aws/kms/KMSComponentSpringTest-context.xml
deleted file mode 100644
index 42eccfd..0000000
--- a/components/camel-aws-msk/bin/src/test/resources/org/apache/camel/component/aws/kms/KMSComponentSpringTest-context.xml
+++ /dev/null
@@ -1,60 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:listKeys"/>
- <to uri="aws-kms://Test?kmsClient=#amazonKmsClient&operation=listKeys"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:createKey"/>
- <to uri="aws-kms://Test?kmsClient=#amazonKmsClient&operation=createKey"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:disableKey"/>
- <to uri="aws-kms://Test?kmsClient=#amazonKmsClient&operation=disableKey"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:enableKey"/>
- <to uri="aws-kms://Test?kmsClient=#amazonKmsClient&operation=enableKey"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:scheduleDelete"/>
- <to uri="aws-kms://Test?kmsClient=#amazonKmsClient&operation=scheduleKeyDeletion"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:describeKey"/>
- <to uri="aws-kms://Test?kmsClient=#amazonKmsClient&operation=describeKey"/>
- <to uri="mock:result"/>
- </route>
- </camelContext>
-
- <bean id="amazonKmsClient" class="org.apache.camel.component.aws.kms.AmazonKMSClientMock"/>
-</beans>
\ No newline at end of file
diff --git a/components/pom.xml b/components/pom.xml
index bf36f6b..b789c0c 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -102,6 +102,7 @@
<module>camel-aws-kms</module>
<module>camel-aws-lambda</module>
<module>camel-aws-mq</module>
+ <module>camel-aws-msk</module>
<module>camel-aws-s3</module>
<module>camel-aws-sdb</module>
<module>camel-aws-ses</module>
diff --git a/parent/pom.xml b/parent/pom.xml
index 3a91c6a..ad8f061 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -961,6 +961,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3</artifactId>
<version>${project.version}</version>
</dependency>
@@ -2485,6 +2490,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3-starter</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml b/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
index d9da156..1fdaa1f 100644
--- a/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
+++ b/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
@@ -493,6 +493,16 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-aws-msk-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3</artifactId>
<version>${project.version}</version>
</dependency>