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:58 UTC
[camel] branch master updated (ae92838 -> 48b2cb9)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from ae92838 Regen website docs
new b2643ea Camel-AWS2-MSK: Added createBroker example
new 7086e75 Camel-AWS2-MSK: Added deleteCluster example
new 70bd734 Camel-AWS2-MSK: Improved docs
new 48b2cb9 Regen website docs
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/docs/aws2-msk-component.adoc | 45 +++++++++++++++++++++-
.../modules/ROOT/pages/aws2-msk-component.adoc | 45 +++++++++++++++++++++-
2 files changed, 88 insertions(+), 2 deletions(-)
[camel] 03/04: Camel-AWS2-MSK: Improved docs
Posted by ac...@apache.org.
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 70bd734584a735706a278a8b9b3cdcdf259cbb8a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Aug 3 19:46:13 2020 +0200
Camel-AWS2-MSK: Improved docs
---
components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 213ab81..0800ce7 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
@@ -151,7 +151,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]
--------------------------------------------------------------------------------
[camel] 02/04: Camel-AWS2-MSK: Added deleteCluster example
Posted by ac...@apache.org.
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 7086e750fa6c22337af2b254dc096d9e7b0b34ad
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Aug 3 19:45:43 2020 +0200
Camel-AWS2-MSK: Added deleteCluster example
---
.../src/main/docs/aws2-msk-component.adoc | 27 +++++++++++++++++++++-
1 file changed, 26 insertions(+), 1 deletion(-)
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 121a363..213ab81 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,7 +159,7 @@ from("direct:listClusters")
.to("aws2-msk://test?mskClient=#amazonMskClient&operation=listClusters")
--------------------------------------------------------------------------------
-- createBroker: this operation will create an MSK Cluster in AWS
+- createCluster: this operation will create an MSK Cluster in AWS
[source,java]
--------------------------------------------------------------------------------
@@ -177,6 +177,31 @@ from("direct:createCluster")
.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.
[camel] 04/04: Regen website docs
Posted by ac...@apache.org.
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 <an...@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.
[camel] 01/04: Camel-AWS2-MSK: Added createBroker example
Posted by ac...@apache.org.
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.