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 48b2cb97c7a4df778e4601b2e7828e2c9f9d0cee
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Aug 3 19:47:17 2020 +0200
Regen website docs
---
.../modules/ROOT/pages/aws2-msk-component.adoc | 45 +++++++++++++++++++++-
1 file changed, 44 insertions(+), 1 deletion(-)
diff --git a/docs/components/modules/ROOT/pages/aws2-msk-component.adoc
b/docs/components/modules/ROOT/pages/aws2-msk-component.adoc
index 485be0d..98698fc 100644
--- a/docs/components/modules/ROOT/pages/aws2-msk-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-msk-component.adoc
@@ -153,7 +153,7 @@ Camel-AWS MSK component provides the following operation on
the producer side:
== Producer Examples
-- listBrokers: this operation will list the available MSK Brokers in AWS
+- listClusters: this operation will list the available MSK Brokers in AWS
[source,java]
--------------------------------------------------------------------------------
@@ -161,6 +161,49 @@ from("direct:listClusters")
.to("aws2-msk://test?mskClient=#amazonMskClient&operation=listClusters")
--------------------------------------------------------------------------------
+- createCluster: 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")
+--------------------------------------------------------------------------------
+
+- deleteCluster: this operation will delete an MSK Cluster in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:deleteCluster")
+ .setHeader(MSK2Constants.CLUSTER_ARN, constant("test-kafka"));
+ .to("aws2-msk://test?mskClient=#amazonMskClient&operation=deleteCluster")
+--------------------------------------------------------------------------------
+
+[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=deleteCluster")
+--------------------------------------------------------------------------------
+
== Automatic detection of KafkaClient client in registry
The component is capable of detecting the presence of an KafkaClient bean into
the registry.
