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 2020/08/03 17:47:59 UTC
[camel] 01/04: Camel-AWS2-MSK: Added createBroker example
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 b2643eaeecf196a6ea73405c5e2f28f4e7fc4625
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Aug 3 19:44:01 2020 +0200
Camel-AWS2-MSK: Added createBroker example
---
.../src/main/docs/aws2-msk-component.adoc | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git a/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc b/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc
index 42665df..121a363 100644
--- a/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc
+++ b/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc
@@ -159,6 +159,24 @@ from("direct:listClusters")
.to("aws2-msk://test?mskClient=#amazonMskClient&operation=listClusters")
--------------------------------------------------------------------------------
+- createBroker: this operation will create an MSK Cluster in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:createCluster")
+ .process(new Processor() {
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setHeader(MSK2Constants.CLUSTER_NAME, "test-kafka");
+ exchange.getIn().setHeader(MSK2Constants.CLUSTER_KAFKA_VERSION, "2.1.1");
+ exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_NUMBER, 2);
+ BrokerNodeGroupInfo groupInfo = BrokerNodeGroupInfo.builder().build();
+ exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_GROUP_INFO, groupInfo);
+ }
+ })
+ .to("aws2-msk://test?mskClient=#amazonMskClient&operation=createCluster")
+--------------------------------------------------------------------------------
+
== Automatic detection of KafkaClient client in registry
The component is capable of detecting the presence of an KafkaClient bean into the registry.