This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/camel-kafka-connector-0.7.x by
this push:
new dd8f526 Upgrade to 3.7.1 and regen
dd8f526 is described below
commit dd8f52658a1047ec3379946d8b111aec36aa4b84
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jan 22 18:20:21 2021 +0100
Upgrade to 3.7.1 and regen
---
.../resources/connectors/camel-activemq-sink.json | 2 +-
.../resources/connectors/camel-activemq-source.json | 2 +-
.../src/generated/resources/connectors/camel-ahc-sink.json | 2 +-
.../generated/resources/connectors/camel-ahc-ws-sink.json | 2 +-
.../resources/connectors/camel-ahc-ws-source.json | 2 +-
.../generated/resources/connectors/camel-ahc-wss-sink.json | 2 +-
.../resources/connectors/camel-ahc-wss-source.json | 2 +-
.../generated/resources/connectors/camel-amqp-sink.json | 2 +-
.../generated/resources/connectors/camel-amqp-source.json | 2 +-
.../generated/resources/connectors/camel-apns-sink.json | 2 +-
.../generated/resources/connectors/camel-apns-source.json | 2 +-
.../resources/connectors/camel-arangodb-sink.json | 2 +-
.../src/generated/resources/connectors/camel-as2-sink.json | 2 +-
.../generated/resources/connectors/camel-as2-source.json | 2 +-
.../resources/connectors/camel-asterisk-sink.json | 2 +-
.../resources/connectors/camel-asterisk-source.json | 2 +-
.../resources/connectors/camel-atlasmap-sink.json | 2 +-
.../generated/resources/connectors/camel-atmos-sink.json | 2 +-
.../generated/resources/connectors/camel-atmos-source.json | 2 +-
.../connectors/camel-atmosphere-websocket-sink.json | 2 +-
.../connectors/camel-atmosphere-websocket-source.json | 2 +-
.../generated/resources/connectors/camel-atom-source.json | 2 +-
.../resources/connectors/camel-atomix-map-sink.json | 2 +-
.../resources/connectors/camel-atomix-map-source.json | 2 +-
.../resources/connectors/camel-atomix-messaging-sink.json | 2 +-
.../connectors/camel-atomix-messaging-source.json | 2 +-
.../resources/connectors/camel-atomix-multimap-sink.json | 2 +-
.../resources/connectors/camel-atomix-queue-sink.json | 2 +-
.../resources/connectors/camel-atomix-queue-source.json | 2 +-
.../resources/connectors/camel-atomix-set-sink.json | 2 +-
.../resources/connectors/camel-atomix-set-source.json | 2 +-
.../resources/connectors/camel-atomix-value-sink.json | 2 +-
.../resources/connectors/camel-atomix-value-source.json | 2 +-
.../generated/resources/connectors/camel-avro-sink.json | 2 +-
.../generated/resources/connectors/camel-avro-source.json | 2 +-
.../generated/resources/connectors/camel-aws-cw-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-ddb-sink.json | 2 +-
.../resources/connectors/camel-aws-ddbstream-source.json | 2 +-
.../generated/resources/connectors/camel-aws-ec2-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-ecs-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-eks-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-iam-sink.json | 2 +-
.../connectors/camel-aws-kinesis-firehose-sink.json | 2 +-
.../resources/connectors/camel-aws-kinesis-sink.json | 2 +-
.../resources/connectors/camel-aws-kinesis-source.json | 2 +-
.../generated/resources/connectors/camel-aws-kms-sink.json | 2 +-
.../resources/connectors/camel-aws-lambda-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-mq-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-msk-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-s3-sink.json | 2 +-
.../resources/connectors/camel-aws-s3-source.json | 2 +-
.../generated/resources/connectors/camel-aws-sdb-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-ses-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-sns-sink.json | 2 +-
.../generated/resources/connectors/camel-aws-sqs-sink.json | 2 +-
.../resources/connectors/camel-aws-sqs-source.json | 2 +-
.../generated/resources/connectors/camel-aws-swf-sink.json | 2 +-
.../resources/connectors/camel-aws-swf-source.json | 2 +-
.../resources/connectors/camel-aws-translate-sink.json | 2 +-
.../resources/connectors/camel-aws2-athena-sink.json | 2 +-
.../generated/resources/connectors/camel-aws2-cw-sink.json | 2 +-
.../resources/connectors/camel-aws2-ddb-sink.json | 2 +-
.../resources/connectors/camel-aws2-ddbstream-source.json | 2 +-
.../resources/connectors/camel-aws2-ec2-sink.json | 2 +-
.../resources/connectors/camel-aws2-ecs-sink.json | 2 +-
.../resources/connectors/camel-aws2-eks-sink.json | 2 +-
.../resources/connectors/camel-aws2-eventbridge-sink.json | 2 +-
.../resources/connectors/camel-aws2-iam-sink.json | 14 +++++++-------
.../src/generated/resources/camel-aws2-iam-sink.json | 12 ++++++------
.../src/main/docs/camel-aws2-iam-kafka-sink-connector.adoc | 4 ++--
.../docs/examples/CamelAws2iamSinkConnector.properties | 4 ----
.../aws2iam/CamelAws2iamSinkConnectorConfig.java | 8 ++++----
.../org/apache/camel/kafkaconnector/DataFormatTest.java | 3 +--
.../connectors/camel-aws2-iam-kafka-sink-connector.adoc | 4 ++--
parent/pom.xml | 2 +-
pom.xml | 2 +-
76 files changed, 91 insertions(+), 96 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-sink.json
index eb510b0..61ed3d9 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-activemq-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send messages to (or consume from) Apache
ActiveMQ. This component extends the Camel JMS component."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
index feebe71..5cca5c9 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-activemq-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send messages to (or consume from) Apache
ActiveMQ. This component extends the Camel JMS component."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-sink.json
index 81362f9..e009c17 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-ahc-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Call external HTTP services using Async Http
Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-sink.json
index 38f671e..ec7b44f 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-ahc-ws-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Exchange data with external Websocket servers
using Async Http Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-source.json
index 8e61c7c..59b92a0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-ws-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-ahc-ws-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Exchange data with external Websocket servers
using Async Http Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-sink.json
index f46eff2..1d93418 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-ahc-wss-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Exchange data with external Websocket servers
using Async Http Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-source.json
index 070bf85..0d7b4d4 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-ahc-wss-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-ahc-wss-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Exchange data with external Websocket servers
using Async Http Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-sink.json
index b925bce..e6df82d 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-amqp-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Messaging with AMQP protocol using Apache QPid
Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-source.json
index b78fc10..5366c63 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-amqp-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-amqp-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Messaging with AMQP protocol using Apache QPid
Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-sink.json
index c1497bf..19bedcb 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-apns-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send notifications to Apple iOS devices."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-source.json
index cb6c61c..92e1671 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-apns-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-apns-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send notifications to Apple iOS devices."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-arangodb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-arangodb-sink.json
index da9cb22..a574caa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-arangodb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-arangodb-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-arangodb-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Perform operations on ArangoDb when used as a
Document Database, or as a Graph Database"
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-sink.json
index 686758e..5ac90a7 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-as2-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Transfer data securely and reliably using the
AS2 protocol (RFC4130)."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-source.json
index 65f51fa..0ca91b9 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-as2-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-as2-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Transfer data securely and reliably using the
AS2 protocol (RFC4130)."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-sink.json
index 5609cc6..25b262c 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-asterisk-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Interact with Asterisk PBX Server."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-source.json
index 919819b..dff1a11 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-asterisk-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-asterisk-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Interact with Asterisk PBX Server."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atlasmap-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atlasmap-sink.json
index 1b21a9b..2f8e3a3 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atlasmap-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atlasmap-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atlasmap-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Transforms the message using an AtlasMap
transformation."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-sink.json
index 23326fc..8902b47 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atmos-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Integrate with EMC's ViPR object data services
using the Atmos Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-source.json
index 75815ef..ea145e7 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmos-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atmos-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Integrate with EMC's ViPR object data services
using the Atmos Client."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-sink.json
index 9ae56ca..84d0de0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atmosphere-websocket-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Expose WebSocket endpoints using the Atmosphere
framework."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-source.json
index b98ecd2..e396667 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atmosphere-websocket-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atmosphere-websocket-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Expose WebSocket endpoints using the Atmosphere
framework."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atom-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atom-source.json
index 8e1e656..eea7b75 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atom-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atom-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atom-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Poll Atom RSS feeds."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-sink.json
index 81e546a..ce8291a 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-map-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed map."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-source.json
index 7c2d4a0..80df309 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-map-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-map-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed map."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-sink.json
index 6d492cc..723e9ae 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-messaging-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's group messaging."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-source.json
index 9e2ee9d..584e5eb 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-messaging-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-messaging-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's group messaging."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-multimap-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-multimap-sink.json
index 50202b5..a2367bd 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-multimap-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-multimap-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-multimap-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed multi map."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-sink.json
index 3404358..62f963a 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-queue-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed queue."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-source.json
index fbfac23..2e1ca33 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-queue-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-queue-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed queue."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-sink.json
index e459638..e14858b 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-set-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed set."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-source.json
index 9b2b48b..18b5ada 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-set-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-set-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed set."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-sink.json
index 404feb0..bbd18b1 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-value-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed value."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-source.json
index 0360975..eefc3d0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-atomix-value-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-atomix-value-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access Atomix's distributed value."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-sink.json
index 0be4775..704f333 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-avro-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Produce or consume Apache Avro RPC services."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-source.json
index 8d41ed3..33444de 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-avro-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-avro-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Produce or consume Apache Avro RPC services."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cw-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cw-sink.json
index 0cc490b..c4533b7 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cw-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cw-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-cw-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send metrics to AWS CloudWatch."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddb-sink.json
index 89a2c5b..b6c9d08 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddb-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-ddb-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Store and retrieve data from AWS DynamoDB
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddbstream-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddbstream-source.json
index 600d5f7..c42148f 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddbstream-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ddbstream-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-ddbstream-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Receive messages from AWS DynamoDB Stream
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ec2-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ec2-sink.json
index 118d8af..404db98 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ec2-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ec2-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-ec2-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS EC2 instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ecs-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ecs-sink.json
index 161e878..22fd273 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ecs-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ecs-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-ecs-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS ECS cluster instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-eks-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-eks-sink.json
index d13bdc1..def9312 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-eks-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-eks-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-eks-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS EKS cluster instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-iam-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-iam-sink.json
index ae6cd34..3063d45 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-iam-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-iam-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-iam-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS IAM instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-firehose-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-firehose-sink.json
index 7901e29..46bba51 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-firehose-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-firehose-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-kinesis-firehose-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Consume data from AWS Kinesis Firehose streams."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-sink.json
index 28d2550..8ab9c8a 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-kinesis-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Consume and produce records from AWS Kinesis
Streams."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-source.json
index 9fe6559..d96f7c7 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kinesis-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-kinesis-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Consume and produce records from AWS Kinesis
Streams."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kms-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kms-sink.json
index 5291dae..77a075f 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kms-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-kms-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-kms-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage keys stored in AWS KMS instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-lambda-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-lambda-sink.json
index 9487954..6a7dbcb 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-lambda-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-lambda-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-lambda-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage and invoke AWS Lambda functions."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-mq-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-mq-sink.json
index f6bafcb..2f923aa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-mq-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-mq-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-mq-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS MQ instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-msk-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-msk-sink.json
index d95a92a..b54e3b2 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-msk-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-msk-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-msk-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS MSK instances."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
index 745ec0e..183aecc 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-s3-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Store and retrieve objects from AWS S3 Storage
Service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
index ac45220..c9b7698 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-s3-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Store and retrieve objects from AWS S3 Storage
Service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sdb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sdb-sink.json
index cdc976c..a04bdc3 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sdb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sdb-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-sdb-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Store and Retrieve data from\/to AWS SDB
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ses-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ses-sink.json
index 8d99b8d..8435fd8 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ses-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-ses-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-ses-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send e-mails through AWS SES service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sns-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sns-sink.json
index 59706b1..4ba7003 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sns-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sns-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-sns-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Send messages to an AWS Simple Notification
Topic."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-sink.json
index 9318978..4e63d6d 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-sqs-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Sending and receive messages to\/from AWS SQS
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-source.json
index 1ec110c..d3a7883 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-sqs-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-sqs-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Sending and receive messages to\/from AWS SQS
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-sink.json
index 0b92fce..0c51048 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-swf-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage workflows in the AWS Simple Workflow
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-source.json
index 07addd4..3fae5fe 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-swf-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-swf-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage workflows in the AWS Simple Workflow
service."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-translate-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-translate-sink.json
index a71deb9..cc474cd 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-translate-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-translate-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws-translate-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Translate texts using AWS Translate."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-athena-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-athena-sink.json
index 5cd54f3..b5c8e3a 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-athena-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-athena-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-athena-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Access AWS Athena service using AWS SDK version
2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
index f548f31..d8a351b 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-cw-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Sending metrics to AWS CloudWatch using AWS SDK
version 2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddb-sink.json
index fcec49f..68e16a9 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddb-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-ddb-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Store and retrieve data from AWS DynamoDB
service using AWS SDK version 2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddbstream-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddbstream-source.json
index a548349..bfafec2 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddbstream-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddbstream-source.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-ddbstream-source",
"type": "source",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Receive messages from AWS DynamoDB Stream
service using AWS SDK version 2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ec2-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ec2-sink.json
index 62d5398..601b7cb 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ec2-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ec2-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-ec2-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS EC2 instances using AWS SDK version
2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ecs-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ecs-sink.json
index 68985ed..1298d85 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ecs-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ecs-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-ecs-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS ECS cluster instances using AWS SDK
version 2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eks-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eks-sink.json
index 6f4c95a..7be5811 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eks-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eks-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-eks-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS EKS cluster instances using AWS SDK
version 2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
index 66cc2a6..d7dcafb 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-eventbridge-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS Eventbridge cluster instances using
AWS SDK version 2.x."
},
"properties": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-iam-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-iam-sink.json
index 02b3282..4083b9c 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-iam-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-iam-sink.json
@@ -5,7 +5,7 @@
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-aws2-iam-sink",
"type": "sink",
- "version": "0.8.0-SNAPSHOT",
+ "version": "0.7.1-SNAPSHOT",
"description": "Manage AWS IAM instances using AWS SDK version
2.x."
},
"properties": {
@@ -30,9 +30,9 @@
},
"camel.sink.endpoint.operation": {
"name": "camel.sink.endpoint.operation",
- "description": "The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
- "priority": "HIGH",
- "required": "true",
+ "description": "The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
+ "priority": "MEDIUM",
+ "required": "false",
"enum": [
"listAccessKeys",
"createUser",
@@ -133,9 +133,9 @@
},
"camel.component.aws2-iam.operation": {
"name": "camel.component.aws2-iam.operation",
- "description": "The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
- "priority": "HIGH",
- "required": "true",
+ "description": "The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
+ "priority": "MEDIUM",
+ "required": "false",
"enum": [
"listAccessKeys",
"createUser",
diff --git
a/connectors/camel-aws2-iam-kafka-connector/src/generated/resources/camel-aws2-iam-sink.json
b/connectors/camel-aws2-iam-kafka-connector/src/generated/resources/camel-aws2-iam-sink.json
index 8c4baa8..4083b9c 100644
---
a/connectors/camel-aws2-iam-kafka-connector/src/generated/resources/camel-aws2-iam-sink.json
+++
b/connectors/camel-aws2-iam-kafka-connector/src/generated/resources/camel-aws2-iam-sink.json
@@ -30,9 +30,9 @@
},
"camel.sink.endpoint.operation": {
"name": "camel.sink.endpoint.operation",
- "description": "The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
- "priority": "HIGH",
- "required": "true",
+ "description": "The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
+ "priority": "MEDIUM",
+ "required": "false",
"enum": [
"listAccessKeys",
"createUser",
@@ -133,9 +133,9 @@
},
"camel.component.aws2-iam.operation": {
"name": "camel.component.aws2-iam.operation",
- "description": "The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
- "priority": "HIGH",
- "required": "true",
+ "description": "The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]",
+ "priority": "MEDIUM",
+ "required": "false",
"enum": [
"listAccessKeys",
"createUser",
diff --git
a/connectors/camel-aws2-iam-kafka-connector/src/main/docs/camel-aws2-iam-kafka-sink-connector.adoc
b/connectors/camel-aws2-iam-kafka-connector/src/main/docs/camel-aws2-iam-kafka-sink-connector.adoc
index 2478c9a..4ac9c8c 100644
---
a/connectors/camel-aws2-iam-kafka-connector/src/main/docs/camel-aws2-iam-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-iam-kafka-connector/src/main/docs/camel-aws2-iam-kafka-sink-connector.adoc
@@ -32,7 +32,7 @@ The camel-aws2-iam sink connector supports 26 options, which
are listed below.
| *camel.sink.path.label* | Logical name | null | true | HIGH
| *camel.sink.endpoint.iamClient* | To use a existing configured AWS IAM as
client | null | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
-| *camel.sink.endpoint.operation* | The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null | true
| HIGH
+| *camel.sink.endpoint.operation* | The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null |
false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the IAM client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the IAM client | null | false | MEDIUM
@@ -45,7 +45,7 @@ The camel-aws2-iam sink connector supports 26 options, which
are listed below.
| *camel.component.aws2-iam.configuration* | Component configuration | null |
false | MEDIUM
| *camel.component.aws2-iam.iamClient* | To use a existing configured AWS IAM
as client | null | false | MEDIUM
| *camel.component.aws2-iam.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed the [...]
-| *camel.component.aws2-iam.operation* | The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null | true
| HIGH
+| *camel.component.aws2-iam.operation* | The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null |
false | MEDIUM
| *camel.component.aws2-iam.pojoRequest* | If we want to use a POJO request as
body or not | false | false | MEDIUM
| *camel.component.aws2-iam.proxyHost* | To define a proxy host when
instantiating the IAM client | null | false | MEDIUM
| *camel.component.aws2-iam.proxyPort* | To define a proxy port when
instantiating the IAM client | null | false | MEDIUM
diff --git
a/connectors/camel-aws2-iam-kafka-connector/src/main/docs/examples/CamelAws2iamSinkConnector.properties
b/connectors/camel-aws2-iam-kafka-connector/src/main/docs/examples/CamelAws2iamSinkConnector.properties
index 0ebb09f..4655785 100644
---
a/connectors/camel-aws2-iam-kafka-connector/src/main/docs/examples/CamelAws2iamSinkConnector.properties
+++
b/connectors/camel-aws2-iam-kafka-connector/src/main/docs/examples/CamelAws2iamSinkConnector.properties
@@ -28,10 +28,6 @@ topics=
# mandatory properties (for a complete properties list see the connector
documentation):
-# The operation to perform One of: [listAccessKeys] [createUser] [deleteUser]
[getUser] [listUsers] [createAccessKey] [deleteAccessKey] [updateAccessKey]
[createGroup] [deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]
-camel.component.aws2-iam.operation=
-# The operation to perform One of: [listAccessKeys] [createUser] [deleteUser]
[getUser] [listUsers] [createAccessKey] [deleteAccessKey] [updateAccessKey]
[createGroup] [deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup]
-camel.sink.endpoint.operation=
# Logical name
camel.sink.path.label=
diff --git
a/connectors/camel-aws2-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2iam/CamelAws2iamSinkConnectorConfig.java
b/connectors/camel-aws2-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2iam/CamelAws2iamSinkConnectorConfig.java
index 6d2ffbb..5d5bc5e 100644
---
a/connectors/camel-aws2-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2iam/CamelAws2iamSinkConnectorConfig.java
+++
b/connectors/camel-aws2-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2iam/CamelAws2iamSinkConnectorConfig.java
@@ -34,7 +34,7 @@ public class CamelAws2iamSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2IAM_ENDPOINT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that wh [...]
public static final Boolean
CAMEL_SINK_AWS2IAM_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_CONF =
"camel.sink.endpoint.operation";
- public static final String CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DOC =
"The operation to perform One of: [listAccessKeys] [createUser] [deleteUser]
[getUser] [listUsers] [createAccessKey] [deleteAccessKey] [updateAccessKey]
[createGroup] [deleteGroup] [listGroups] [addUserToGroup]
[removeUserFromGroup]";
+ public static final String CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DOC =
"The operation to perform. You can configure a default operation on the
component level, or the operation as part of the endpoint, or via a message
header with the key CamelAwsIAMOperation. One of: [listAccessKeys] [createUser]
[deleteUser] [getUser] [listUsers] [createAccessKey] [deleteAccessKey]
[updateAccessKey] [createGroup] [deleteGroup] [listGroups] [addUserToGroup]
[removeUserFromGroup]";
public static final String CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DEFAULT =
null;
public static final String CAMEL_SINK_AWS2IAM_ENDPOINT_POJO_REQUEST_CONF =
"camel.sink.endpoint.pojoRequest";
public static final String CAMEL_SINK_AWS2IAM_ENDPOINT_POJO_REQUEST_DOC =
"If we want to use a POJO request as body or not";
@@ -73,7 +73,7 @@ public class CamelAws2iamSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2IAM_COMPONENT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that w [...]
public static final Boolean
CAMEL_SINK_AWS2IAM_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_CONF =
"camel.component.aws2-iam.operation";
- public static final String CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DOC =
"The operation to perform One of: [listAccessKeys] [createUser] [deleteUser]
[getUser] [listUsers] [createAccessKey] [deleteAccessKey] [updateAccessKey]
[createGroup] [deleteGroup] [listGroups] [addUserToGroup]
[removeUserFromGroup]";
+ public static final String CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DOC =
"The operation to perform. You can configure a default operation on the
component level, or the operation as part of the endpoint, or via a message
header with the key CamelAwsIAMOperation. One of: [listAccessKeys] [createUser]
[deleteUser] [getUser] [listUsers] [createAccessKey] [deleteAccessKey]
[updateAccessKey] [createGroup] [deleteGroup] [listGroups] [addUserToGroup]
[removeUserFromGroup]";
public static final String CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DEFAULT
= null;
public static final String CAMEL_SINK_AWS2IAM_COMPONENT_POJO_REQUEST_CONF
= "camel.component.aws2-iam.pojoRequest";
public static final String CAMEL_SINK_AWS2IAM_COMPONENT_POJO_REQUEST_DOC =
"If we want to use a POJO request as body or not";
@@ -118,7 +118,7 @@ public class CamelAws2iamSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2IAM_PATH_LABEL_CONF, ConfigDef.Type.STRING,
CAMEL_SINK_AWS2IAM_PATH_LABEL_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SINK_AWS2IAM_PATH_LABEL_DOC);
conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_IAM_CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_ENDPOINT_IAM_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_ENDPOINT_IAM_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2IAM_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2IAM_ENDPOINT_LAZY_START_PRODUCER_DOC);
- conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DOC);
+ conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_ENDPOINT_OPERATION_DOC);
conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2IAM_ENDPOINT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_ENDPOINT_POJO_REQUEST_DOC);
conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2IAM_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_ENDPOINT_PROXY_PORT_DOC);
@@ -131,7 +131,7 @@ public class CamelAws2iamSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_IAM_CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_COMPONENT_IAM_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_COMPONENT_IAM_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2IAM_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2IAM_COMPONENT_LAZY_START_PRODUCER_DOC);
- conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DOC);
+ conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_COMPONENT_OPERATION_DOC);
conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2IAM_COMPONENT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_COMPONENT_POJO_REQUEST_DOC);
conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_COMPONENT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2IAM_COMPONENT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2IAM_COMPONENT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2IAM_COMPONENT_PROXY_PORT_DOC);
diff --git
a/core/src/test/java/org/apache/camel/kafkaconnector/DataFormatTest.java
b/core/src/test/java/org/apache/camel/kafkaconnector/DataFormatTest.java
index 4e309d4..6715843 100644
--- a/core/src/test/java/org/apache/camel/kafkaconnector/DataFormatTest.java
+++ b/core/src/test/java/org/apache/camel/kafkaconnector/DataFormatTest.java
@@ -29,7 +29,6 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows;
-import static org.junit.jupiter.api.Assertions.assertTrue;
public class DataFormatTest {
@@ -141,7 +140,7 @@ public class DataFormatTest {
cms.start();
HL7DataFormat hl7dfLoaded =
(HL7DataFormat)dcc.resolveDataFormat("hl7");
- assertTrue(hl7dfLoaded.isValidate());
+ assertFalse(hl7dfLoaded.isValidate());
cms.stop();
}
}
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-iam-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-iam-kafka-sink-connector.adoc
index 2478c9a..4ac9c8c 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-iam-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-iam-kafka-sink-connector.adoc
@@ -32,7 +32,7 @@ The camel-aws2-iam sink connector supports 26 options, which
are listed below.
| *camel.sink.path.label* | Logical name | null | true | HIGH
| *camel.sink.endpoint.iamClient* | To use a existing configured AWS IAM as
client | null | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
-| *camel.sink.endpoint.operation* | The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null | true
| HIGH
+| *camel.sink.endpoint.operation* | The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null |
false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the IAM client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the IAM client | null | false | MEDIUM
@@ -45,7 +45,7 @@ The camel-aws2-iam sink connector supports 26 options, which
are listed below.
| *camel.component.aws2-iam.configuration* | Component configuration | null |
false | MEDIUM
| *camel.component.aws2-iam.iamClient* | To use a existing configured AWS IAM
as client | null | false | MEDIUM
| *camel.component.aws2-iam.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed the [...]
-| *camel.component.aws2-iam.operation* | The operation to perform One of:
[listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null | true
| HIGH
+| *camel.component.aws2-iam.operation* | The operation to perform. You can
configure a default operation on the component level, or the operation as part
of the endpoint, or via a message header with the key CamelAwsIAMOperation. One
of: [listAccessKeys] [createUser] [deleteUser] [getUser] [listUsers]
[createAccessKey] [deleteAccessKey] [updateAccessKey] [createGroup]
[deleteGroup] [listGroups] [addUserToGroup] [removeUserFromGroup] | null |
false | MEDIUM
| *camel.component.aws2-iam.pojoRequest* | If we want to use a POJO request as
body or not | false | false | MEDIUM
| *camel.component.aws2-iam.proxyHost* | To define a proxy host when
instantiating the IAM client | null | false | MEDIUM
| *camel.component.aws2-iam.proxyPort* | To define a proxy port when
instantiating the IAM client | null | false | MEDIUM
diff --git a/parent/pom.xml b/parent/pom.xml
index 0a97a31..91bf637 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -28,7 +28,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<kafka.version>2.6.0</kafka.version>
- <camel.version>3.7.1-SNAPSHOT</camel.version>
+ <camel.version>3.7.1</camel.version>
<apicurio.registry.version>1.3.1.Final</apicurio.registry.version>
<resteasy.version>4.5.6.Final</resteasy.version>
<version.java>1.8</version.java>
diff --git a/pom.xml b/pom.xml
index 5419e23..1721786 100644
--- a/pom.xml
+++ b/pom.xml
@@ -23,7 +23,7 @@
<parent>
<groupId>org.apache.camel</groupId>
<artifactId>camel-dependencies</artifactId>
- <version>3.7.1-SNAPSHOT</version>
+ <version>3.7.1</version>
</parent>
<groupId>org.apache.camel.kafkaconnector</groupId>
