This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/camel-master by this push:
new 769287c [create-pull-request] automated change
769287c is described below
commit 769287cc25cedf12abba5cc9c09f99c715608a87
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Nov 28 03:51:43 2020 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-aws2-sns-sink.json | 26 ++++++++++++++++++++++
.../generated/resources/camel-aws2-sns-sink.json | 26 ++++++++++++++++++++++
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 6 ++++-
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 16 +++++++++++++
.../camel-aws2-sns-kafka-sink-connector.adoc | 6 ++++-
5 files changed, 78 insertions(+), 2 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
index 49fb584..2c00bb4 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
@@ -47,6 +47,19 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.messageDeduplicationIdStrategy": {
+ "name":
"camel.sink.endpoint.messageDeduplicationIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageDeduplicationId on the message. Can be one of the following
options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication]",
+ "defaultValue": "\"useExchangeId\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.messageGroupIdStrategy": {
+ "name": "camel.sink.endpoint.messageGroupIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. One of:
[useConstant] [useExchangeId] [usePropertyValue]",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.messageStructure": {
"name": "camel.sink.endpoint.messageStructure",
"description": "The message structure to use such as
json",
@@ -175,6 +188,19 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-sns.messageDeduplicationIdStrategy": {
+ "name":
"camel.component.aws2-sns.messageDeduplicationIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageDeduplicationId on the message. Can be one of the following
options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication]",
+ "defaultValue": "\"useExchangeId\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.aws2-sns.messageGroupIdStrategy": {
+ "name":
"camel.component.aws2-sns.messageGroupIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. One of:
[useConstant] [useExchangeId] [usePropertyValue]",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-sns.messageStructure": {
"name": "camel.component.aws2-sns.messageStructure",
"description": "The message structure to use such as
json",
diff --git
a/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
b/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
index 49fb584..2c00bb4 100644
---
a/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
+++
b/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
@@ -47,6 +47,19 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.messageDeduplicationIdStrategy": {
+ "name":
"camel.sink.endpoint.messageDeduplicationIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageDeduplicationId on the message. Can be one of the following
options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication]",
+ "defaultValue": "\"useExchangeId\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.messageGroupIdStrategy": {
+ "name": "camel.sink.endpoint.messageGroupIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. One of:
[useConstant] [useExchangeId] [usePropertyValue]",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.messageStructure": {
"name": "camel.sink.endpoint.messageStructure",
"description": "The message structure to use such as
json",
@@ -175,6 +188,19 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-sns.messageDeduplicationIdStrategy": {
+ "name":
"camel.component.aws2-sns.messageDeduplicationIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageDeduplicationId on the message. Can be one of the following
options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication]",
+ "defaultValue": "\"useExchangeId\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.aws2-sns.messageGroupIdStrategy": {
+ "name":
"camel.component.aws2-sns.messageGroupIdStrategy",
+ "description": "Only for FIFO Topic. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. One of:
[useConstant] [useExchangeId] [usePropertyValue]",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-sns.messageStructure": {
"name": "camel.component.aws2-sns.messageStructure",
"description": "The message structure to use such as
json",
diff --git
a/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
b/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
index ab19b95..1148c0f 100644
---
a/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2sns.CamelAws2snsSinkConnecto
----
-The camel-aws2-sns sink connector supports 41 options, which are listed below.
+The camel-aws2-sns sink connector supports 45 options, which are listed below.
@@ -35,6 +35,8 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.sink.endpoint.headerFilterStrategy* | To use a custom
HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.sink.endpoint.kmsMasterKeyId* | The ID of an AWS-managed customer
master key (CMK) for Amazon SNS or a custom CMK. | 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.messageDeduplicationIdStrategy* | Only for FIFO Topic.
Strategy for setting the messageDeduplicationId on the message. Can be one of
the following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
+| *camel.sink.endpoint.messageGroupIdStrategy* | Only for FIFO Topic. Strategy
for setting the messageGroupId on the message. Can be one of the following
options: useConstant, useExchangeId, usePropertyValue. For the usePropertyValue
option, the value of property CamelAwsMessageGroupId will be used. One of:
[useConstant] [useExchangeId] [usePropertyValue] | null | false | MEDIUM
| *camel.sink.endpoint.messageStructure* | The message structure to use such
as json | null | false | MEDIUM
| *camel.sink.endpoint.policy* | The policy for this queue | null | false |
MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the SNS client | null | false | MEDIUM
@@ -55,6 +57,8 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.component.aws2-sns.configuration* | Component configuration | null |
false | MEDIUM
| *camel.component.aws2-sns.kmsMasterKeyId* | The ID of an AWS-managed
customer master key (CMK) for Amazon SNS or a custom CMK. | null | false |
MEDIUM
| *camel.component.aws2-sns.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-sns.messageDeduplicationId Strategy* | Only for FIFO
Topic. Strategy for setting the messageDeduplicationId on the message. Can be
one of the following options: useExchangeId, useContentBasedDeduplication. For
the useContentBasedDeduplication option, no messageDeduplicationId will be set
on the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
+| *camel.component.aws2-sns.messageGroupIdStrategy* | Only for FIFO Topic.
Strategy for setting the messageGroupId on the message. Can be one of the
following options: useConstant, useExchangeId, usePropertyValue. For the
usePropertyValue option, the value of property CamelAwsMessageGroupId will be
used. One of: [useConstant] [useExchangeId] [usePropertyValue] | null | false |
MEDIUM
| *camel.component.aws2-sns.messageStructure* | The message structure to use
such as json | null | false | MEDIUM
| *camel.component.aws2-sns.policy* | The policy for this queue | null | false
| MEDIUM
| *camel.component.aws2-sns.proxyHost* | To define a proxy host when
instantiating the SNS client | null | false | MEDIUM
diff --git
a/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
b/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
index 8756009..f3ec556 100644
---
a/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
+++
b/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
@@ -42,6 +42,12 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_LAZY_START_PRODUCER_CONF =
"camel.sink.endpoint.lazyStartProducer";
public static final String
CAMEL_SINK_AWS2SNS_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_AWS2SNS_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_CONF =
"camel.sink.endpoint.messageDeduplicationIdStrategy";
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DOC = "Only for
FIFO Topic. Strategy for setting the messageDeduplicationId on the message. Can
be one of the following options: useExchangeId, useContentBasedDeduplication.
For the useContentBasedDeduplication option, no messageDeduplicationId will be
set on the message. One of: [useExchangeId] [useContentBasedDeduplication]";
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DEFAULT =
"useExchangeId";
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_GROUP_ID_STRATEGY_CONF =
"camel.sink.endpoint.messageGroupIdStrategy";
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_GROUP_ID_STRATEGY_DOC = "Only for FIFO
Topic. Strategy for setting the messageGroupId on the message. Can be one of
the following options: useConstant, useExchangeId, usePropertyValue. For the
usePropertyValue option, the value of property CamelAwsMessageGroupId will be
used. One of: [useConstant] [useExchangeId] [usePropertyValue]";
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_GROUP_ID_STRATEGY_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_STRUCTURE_CONF =
"camel.sink.endpoint.messageStructure";
public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_STRUCTURE_DOC = "The message structure to
use such as json";
public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_STRUCTURE_DEFAULT = null;
@@ -102,6 +108,12 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_LAZY_START_PRODUCER_CONF =
"camel.component.aws2-sns.lazyStartProducer";
public static final String
CAMEL_SINK_AWS2SNS_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_AWS2SNS_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_CONF =
"camel.component.aws2-sns.messageDeduplicationIdStrategy";
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DOC = "Only for
FIFO Topic. Strategy for setting the messageDeduplicationId on the message. Can
be one of the following options: useExchangeId, useContentBasedDeduplication.
For the useContentBasedDeduplication option, no messageDeduplicationId will be
set on the message. One of: [useExchangeId] [useContentBasedDeduplication]";
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DEFAULT =
"useExchangeId";
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_GROUP_ID_STRATEGY_CONF =
"camel.component.aws2-sns.messageGroupIdStrategy";
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_GROUP_ID_STRATEGY_DOC = "Only for FIFO
Topic. Strategy for setting the messageGroupId on the message. Can be one of
the following options: useConstant, useExchangeId, usePropertyValue. For the
usePropertyValue option, the value of property CamelAwsMessageGroupId will be
used. One of: [useConstant] [useExchangeId] [usePropertyValue]";
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_GROUP_ID_STRATEGY_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_STRUCTURE_CONF =
"camel.component.aws2-sns.messageStructure";
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_STRUCTURE_DOC = "The message structure to
use such as json";
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_STRUCTURE_DEFAULT = null;
@@ -166,6 +178,8 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_HEADER_FILTER_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SNS_ENDPOINT_HEADER_FILTER_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_HEADER_FILTER_STRATEGY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_KMS_MASTER_KEY_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_KMS_MASTER_KEY_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_KMS_MASTER_KEY_ID_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_LAZY_START_PRODUCER_DOC);
+
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DOC);
+
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_GROUP_ID_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_GROUP_ID_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_GROUP_ID_STRATEGY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_STRUCTURE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_STRUCTURE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_MESSAGE_STRUCTURE_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_POLICY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_POLICY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_POLICY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_PROXY_HOST_DOC);
@@ -186,6 +200,8 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_KMS_MASTER_KEY_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_KMS_MASTER_KEY_ID_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_KMS_MASTER_KEY_ID_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_LAZY_START_PRODUCER_DOC);
+
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DOC);
+
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_GROUP_ID_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_GROUP_ID_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_GROUP_ID_STRATEGY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_STRUCTURE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_STRUCTURE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_MESSAGE_STRUCTURE_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_POLICY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_POLICY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_COMPONENT_POLICY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_COMPONENT_PROXY_HOST_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
index ab19b95..1148c0f 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2sns.CamelAws2snsSinkConnecto
----
-The camel-aws2-sns sink connector supports 41 options, which are listed below.
+The camel-aws2-sns sink connector supports 45 options, which are listed below.
@@ -35,6 +35,8 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.sink.endpoint.headerFilterStrategy* | To use a custom
HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.sink.endpoint.kmsMasterKeyId* | The ID of an AWS-managed customer
master key (CMK) for Amazon SNS or a custom CMK. | 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.messageDeduplicationIdStrategy* | Only for FIFO Topic.
Strategy for setting the messageDeduplicationId on the message. Can be one of
the following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
+| *camel.sink.endpoint.messageGroupIdStrategy* | Only for FIFO Topic. Strategy
for setting the messageGroupId on the message. Can be one of the following
options: useConstant, useExchangeId, usePropertyValue. For the usePropertyValue
option, the value of property CamelAwsMessageGroupId will be used. One of:
[useConstant] [useExchangeId] [usePropertyValue] | null | false | MEDIUM
| *camel.sink.endpoint.messageStructure* | The message structure to use such
as json | null | false | MEDIUM
| *camel.sink.endpoint.policy* | The policy for this queue | null | false |
MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the SNS client | null | false | MEDIUM
@@ -55,6 +57,8 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.component.aws2-sns.configuration* | Component configuration | null |
false | MEDIUM
| *camel.component.aws2-sns.kmsMasterKeyId* | The ID of an AWS-managed
customer master key (CMK) for Amazon SNS or a custom CMK. | null | false |
MEDIUM
| *camel.component.aws2-sns.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-sns.messageDeduplicationId Strategy* | Only for FIFO
Topic. Strategy for setting the messageDeduplicationId on the message. Can be
one of the following options: useExchangeId, useContentBasedDeduplication. For
the useContentBasedDeduplication option, no messageDeduplicationId will be set
on the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
+| *camel.component.aws2-sns.messageGroupIdStrategy* | Only for FIFO Topic.
Strategy for setting the messageGroupId on the message. Can be one of the
following options: useConstant, useExchangeId, usePropertyValue. For the
usePropertyValue option, the value of property CamelAwsMessageGroupId will be
used. One of: [useConstant] [useExchangeId] [usePropertyValue] | null | false |
MEDIUM
| *camel.component.aws2-sns.messageStructure* | The message structure to use
such as json | null | false | MEDIUM
| *camel.component.aws2-sns.policy* | The policy for this queue | null | false
| MEDIUM
| *camel.component.aws2-sns.proxyHost* | To define a proxy host when
instantiating the SNS client | null | false | MEDIUM
