This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new dbbaa30 [create-pull-request] automated change
dbbaa30 is described below
commit dbbaa30e361d787ac9c2ac175a0a32bd35587e48
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Apr 27 03:57:11 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-aws2-athena-sink.json | 14 ++++++++++++++
.../generated/resources/connectors/camel-aws2-cw-sink.json | 14 ++++++++++++++
.../src/generated/resources/connectors/camel-cql-sink.json | 4 ++--
.../generated/resources/connectors/camel-cql-source.json | 4 ++--
.../generated/resources/connectors/camel-solr-sink.json | 7 +++++++
.../resources/connectors/camel-solrCloud-sink.json | 7 +++++++
.../generated/resources/connectors/camel-solrs-sink.json | 7 +++++++
.../resources/connectors/camel-splunk-hec-sink.json | 14 ++++++++++++++
.../resources/connectors/camel-twitter-timeline-sink.json | 9 ++++++++-
.../connectors/camel-twitter-timeline-source.json | 9 ++++++++-
.../src/generated/resources/camel-aws2-athena-sink.json | 14 ++++++++++++++
.../main/docs/camel-aws2-athena-kafka-sink-connector.adoc | 4 +++-
.../aws2athena/CamelAws2athenaSinkConnectorConfig.java | 8 ++++++++
.../src/generated/resources/camel-aws2-cw-sink.json | 14 ++++++++++++++
.../src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc | 4 +++-
.../aws2cw/CamelAws2cwSinkConnectorConfig.java | 8 ++++++++
.../src/generated/resources/camel-cql-sink.json | 4 ++--
.../src/generated/resources/camel-cql-source.json | 4 ++--
.../src/main/docs/camel-cql-kafka-sink-connector.adoc | 4 ++--
.../src/main/docs/camel-cql-kafka-source-connector.adoc | 4 ++--
.../kafkaconnector/cql/CamelCqlSinkConnectorConfig.java | 4 ++--
.../kafkaconnector/cql/CamelCqlSourceConnectorConfig.java | 4 ++--
.../src/generated/resources/camel-solr-sink.json | 7 +++++++
.../src/main/docs/camel-solr-kafka-sink-connector.adoc | 3 ++-
.../kafkaconnector/solr/CamelSolrSinkConnectorConfig.java | 4 ++++
.../src/generated/resources/camel-solrCloud-sink.json | 7 +++++++
.../main/docs/camel-solrCloud-kafka-sink-connector.adoc | 3 ++-
.../solrcloud/CamelSolrcloudSinkConnectorConfig.java | 4 ++++
.../src/generated/resources/camel-solrs-sink.json | 7 +++++++
.../src/main/docs/camel-solrs-kafka-sink-connector.adoc | 3 ++-
.../solrs/CamelSolrsSinkConnectorConfig.java | 4 ++++
.../src/generated/resources/camel-splunk-hec-sink.json | 14 ++++++++++++++
.../main/docs/camel-splunk-hec-kafka-sink-connector.adoc | 4 +++-
.../splunkhec/CamelSplunkhecSinkConnectorConfig.java | 8 ++++++++
.../generated/resources/camel-twitter-timeline-sink.json | 9 ++++++++-
.../generated/resources/camel-twitter-timeline-source.json | 9 ++++++++-
.../docs/camel-twitter-timeline-kafka-sink-connector.adoc | 5 +++--
.../camel-twitter-timeline-kafka-source-connector.adoc | 5 +++--
.../examples/CamelTwittertimelineSinkConnector.properties | 2 +-
.../CamelTwittertimelineSourceConnector.properties | 2 +-
.../CamelTwittertimelineSinkConnectorConfig.java | 6 +++++-
.../CamelTwittertimelineSourceConnectorConfig.java | 6 +++++-
.../connectors/camel-aws2-athena-kafka-sink-connector.adoc | 4 +++-
.../connectors/camel-aws2-cw-kafka-sink-connector.adoc | 4 +++-
.../pages/connectors/camel-cql-kafka-sink-connector.adoc | 4 ++--
.../pages/connectors/camel-cql-kafka-source-connector.adoc | 4 ++--
.../pages/connectors/camel-solr-kafka-sink-connector.adoc | 3 ++-
.../connectors/camel-solrCloud-kafka-sink-connector.adoc | 3 ++-
.../pages/connectors/camel-solrs-kafka-sink-connector.adoc | 3 ++-
.../connectors/camel-splunk-hec-kafka-sink-connector.adoc | 4 +++-
.../camel-twitter-timeline-kafka-sink-connector.adoc | 5 +++--
.../camel-twitter-timeline-kafka-source-connector.adoc | 5 +++--
52 files changed, 268 insertions(+), 48 deletions(-)
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 22ac49e..83355e3 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
@@ -197,6 +197,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the Athena client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.waitTimeout": {
"name": "camel.sink.endpoint.waitTimeout",
"description": "Optional max wait time in millis to
wait for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more.",
@@ -404,6 +411,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-athena.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-athena.useDefaultCredentialsProvider",
+ "description": "Set whether the Athena client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-athena.waitTimeout": {
"name": "camel.component.aws2-athena.waitTimeout",
"description": "Optional max wait time in millis to
wait for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more.",
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 28b23b2..8a94f96 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
@@ -95,6 +95,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 client should expect
to load credentials through a default credentials provider or to expect static
credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.value": {
"name": "camel.sink.endpoint.value",
"description": "The metric value",
@@ -199,6 +206,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-cw.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-cw.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 client should expect
to load credentials through a default credentials provider or to expect static
credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-cw.value": {
"name": "camel.component.aws2-cw.value",
"description": "The metric value",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
index c16e57a..e54b6b5 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
@@ -17,13 +17,13 @@
},
"camel.sink.path.hosts": {
"name": "camel.sink.path.hosts",
- "description": "Hostname(s) cassansdra server(s).
Multiple hosts can be separated by comma.",
+ "description": "Hostname(s) Cassandra server(s).
Multiple hosts can be separated by comma.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.path.port": {
"name": "camel.sink.path.port",
- "description": "Port number of cassansdra server(s)",
+ "description": "Port number of Cassandra server(s)",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
index e2276f1..dc6bf84 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
@@ -17,13 +17,13 @@
},
"camel.source.path.hosts": {
"name": "camel.source.path.hosts",
- "description": "Hostname(s) cassansdra server(s).
Multiple hosts can be separated by comma.",
+ "description": "Hostname(s) Cassandra server(s).
Multiple hosts can be separated by comma.",
"priority": "MEDIUM",
"required": "false"
},
"camel.source.path.port": {
"name": "camel.source.path.port",
- "description": "Port number of cassansdra server(s)",
+ "description": "Port number of Cassandra server(s)",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json
index faeaca3..9369114 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json
@@ -21,6 +21,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.autoCommit": {
+ "name": "camel.sink.endpoint.autoCommit",
+ "description": "If true, each producer operation will
be committed automatically",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.connectionTimeout": {
"name": "camel.sink.endpoint.connectionTimeout",
"description": "connectionTimeout on the underlying
HttpConnectionManager",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json
index 551bd64..508c2ec 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json
@@ -21,6 +21,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.autoCommit": {
+ "name": "camel.sink.endpoint.autoCommit",
+ "description": "If true, each producer operation will
be committed automatically",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.connectionTimeout": {
"name": "camel.sink.endpoint.connectionTimeout",
"description": "connectionTimeout on the underlying
HttpConnectionManager",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json
index f15e4c2..93ad59e 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json
@@ -21,6 +21,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.autoCommit": {
+ "name": "camel.sink.endpoint.autoCommit",
+ "description": "If true, each producer operation will
be committed automatically",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.connectionTimeout": {
"name": "camel.sink.endpoint.connectionTimeout",
"description": "connectionTimeout on the underlying
HttpConnectionManager",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-splunk-hec-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-splunk-hec-sink.json
index c148edc..d824958 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-splunk-hec-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-splunk-hec-sink.json
@@ -21,6 +21,20 @@
"priority": "HIGH",
"required": "true"
},
+ "camel.sink.endpoint.bodyOnly": {
+ "name": "camel.sink.endpoint.bodyOnly",
+ "description": "Send only the message body",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.headersOnly": {
+ "name": "camel.sink.endpoint.headersOnly",
+ "description": "Send only message headers",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.host": {
"name": "camel.sink.endpoint.host",
"description": "Splunk host.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-sink.json
index f3b6c2f..f63a946 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-sink.json
@@ -11,7 +11,7 @@
"properties": {
"camel.sink.path.timelineType": {
"name": "camel.sink.path.timelineType",
- "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN]",
+ "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN]",
"priority": "HIGH",
"required": "true",
"enum": [
@@ -20,9 +20,16 @@
"USER",
"MENTIONS",
"RETWEETSOFME",
+ "LIST",
"UNKNOWN"
]
},
+ "camel.sink.endpoint.list": {
+ "name": "camel.sink.endpoint.list",
+ "description": "The list name when using
timelineType=list",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.user": {
"name": "camel.sink.endpoint.user",
"description": "The username when using
timelineType=user",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-source.json
index f2464ea..db78afa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-twitter-timeline-source.json
@@ -11,7 +11,7 @@
"properties": {
"camel.source.path.timelineType": {
"name": "camel.source.path.timelineType",
- "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN]",
+ "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN]",
"priority": "HIGH",
"required": "true",
"enum": [
@@ -20,9 +20,16 @@
"USER",
"MENTIONS",
"RETWEETSOFME",
+ "LIST",
"UNKNOWN"
]
},
+ "camel.source.endpoint.list": {
+ "name": "camel.source.endpoint.list",
+ "description": "The list name when using
timelineType=list",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.user": {
"name": "camel.source.endpoint.user",
"description": "The username when using
timelineType=user",
diff --git
a/connectors/camel-aws2-athena-kafka-connector/src/generated/resources/camel-aws2-athena-sink.json
b/connectors/camel-aws2-athena-kafka-connector/src/generated/resources/camel-aws2-athena-sink.json
index 22ac49e..83355e3 100644
---
a/connectors/camel-aws2-athena-kafka-connector/src/generated/resources/camel-aws2-athena-sink.json
+++
b/connectors/camel-aws2-athena-kafka-connector/src/generated/resources/camel-aws2-athena-sink.json
@@ -197,6 +197,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the Athena client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.waitTimeout": {
"name": "camel.sink.endpoint.waitTimeout",
"description": "Optional max wait time in millis to
wait for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more.",
@@ -404,6 +411,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-athena.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-athena.useDefaultCredentialsProvider",
+ "description": "Set whether the Athena client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-athena.waitTimeout": {
"name": "camel.component.aws2-athena.waitTimeout",
"description": "Optional max wait time in millis to
wait for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more.",
diff --git
a/connectors/camel-aws2-athena-kafka-connector/src/main/docs/camel-aws2-athena-kafka-sink-connector.adoc
b/connectors/camel-aws2-athena-kafka-connector/src/main/docs/camel-aws2-athena-kafka-sink-connector.adoc
index c4153ec..ef2eef1 100644
---
a/connectors/camel-aws2-athena-kafka-connector/src/main/docs/camel-aws2-athena-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-athena-kafka-connector/src/main/docs/camel-aws2-athena-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2athena.CamelAws2athenaSinkCo
----
-The camel-aws2-athena sink connector supports 57 options, which are listed
below.
+The camel-aws2-athena sink connector supports 59 options, which are listed
below.
@@ -56,6 +56,7 @@ The camel-aws2-athena sink connector supports 57 options,
which are listed below
| *camel.sink.endpoint.resetWaitTimeoutOnRetry* | Reset the waitTimeout
countdown in the event of a query retry. If set to true, potential max time
spent waiting for queries is equal to waitTimeout x maxAttempts. See the
section 'Waiting for Query Completion and Retrying Failed Queries' to learn
more. | true | false | MEDIUM
| *camel.sink.endpoint.retry* | Optional comma separated list of error types
to retry the query for. Use 'retryable' to retry all retryable failure
conditions (e.g. generic errors and resources exhausted), 'generic' to retry
'GENERIC_INTERNAL_ERROR' failures, 'exhausted' to retry queries that have
exhausted resource limits, 'always' to always retry regardless of failure
condition, or 'never' or null to never retry (default). See the section
'Waiting for Query Completion and Retrying Fail [...]
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key. | null | false |
MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the Athena
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in | false | false | MEDIUM
| *camel.sink.endpoint.waitTimeout* | Optional max wait time in millis to wait
for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more. | 0L | false | MEDIUM
| *camel.sink.endpoint.workGroup* | The workgroup to use for running the
query. | null | false | MEDIUM
| *camel.sink.endpoint.clientRequestToken* | A unique string to ensure issues
queries are idempotent. It is unlikely you will need to set this. | null |
false | MEDIUM
@@ -84,6 +85,7 @@ The camel-aws2-athena sink connector supports 57 options,
which are listed below
| *camel.component.aws2-athena.resetWaitTimeoutOn Retry* | Reset the
waitTimeout countdown in the event of a query retry. If set to true, potential
max time spent waiting for queries is equal to waitTimeout x maxAttempts. See
the section 'Waiting for Query Completion and Retrying Failed Queries' to learn
more. | true | false | MEDIUM
| *camel.component.aws2-athena.retry* | Optional comma separated list of error
types to retry the query for. Use 'retryable' to retry all retryable failure
conditions (e.g. generic errors and resources exhausted), 'generic' to retry
'GENERIC_INTERNAL_ERROR' failures, 'exhausted' to retry queries that have
exhausted resource limits, 'always' to always retry regardless of failure
condition, or 'never' or null to never retry (default). See the section
'Waiting for Query Completion and Retry [...]
| *camel.component.aws2-athena.secretKey* | Amazon AWS Secret Key. | null |
false | MEDIUM
+| *camel.component.aws2-athena.useDefaultCredentials Provider* | Set whether
the Athena client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in | false |
false | MEDIUM
| *camel.component.aws2-athena.waitTimeout* | Optional max wait time in millis
to wait for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more. | 0L | false | MEDIUM
| *camel.component.aws2-athena.workGroup* | The workgroup to use for running
the query. | null | false | MEDIUM
| *camel.component.aws2-athena.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
diff --git
a/connectors/camel-aws2-athena-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2athena/CamelAws2athenaSinkConnectorConfig.java
b/connectors/camel-aws2-athena-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2athena/CamelAws2athenaSinkConnectorConfig.java
index 28e6fe5..99da75a 100644
---
a/connectors/camel-aws2-athena-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2athena/CamelAws2athenaSinkConnectorConfig.java
+++
b/connectors/camel-aws2-athena-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2athena/CamelAws2athenaSinkConnectorConfig.java
@@ -101,6 +101,9 @@ public class CamelAws2athenaSinkConnectorConfig
public static final String CAMEL_SINK_AWS2ATHENA_ENDPOINT_SECRET_KEY_CONF
= "camel.sink.endpoint.secretKey";
public static final String CAMEL_SINK_AWS2ATHENA_ENDPOINT_SECRET_KEY_DOC =
"Amazon AWS Secret Key.";
public static final String
CAMEL_SINK_AWS2ATHENA_ENDPOINT_SECRET_KEY_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2ATHENA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2ATHENA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the Athena client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in";
+ public static final Boolean
CAMEL_SINK_AWS2ATHENA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2ATHENA_ENDPOINT_WAIT_TIMEOUT_CONF =
"camel.sink.endpoint.waitTimeout";
public static final String CAMEL_SINK_AWS2ATHENA_ENDPOINT_WAIT_TIMEOUT_DOC
= "Optional max wait time in millis to wait for a successful query completion.
See the section 'Waiting for Query Completion and Retrying Failed Queries' to
learn more.";
public static final Long
CAMEL_SINK_AWS2ATHENA_ENDPOINT_WAIT_TIMEOUT_DEFAULT = 0L;
@@ -185,6 +188,9 @@ public class CamelAws2athenaSinkConnectorConfig
public static final String CAMEL_SINK_AWS2ATHENA_COMPONENT_SECRET_KEY_CONF
= "camel.component.aws2-athena.secretKey";
public static final String CAMEL_SINK_AWS2ATHENA_COMPONENT_SECRET_KEY_DOC
= "Amazon AWS Secret Key.";
public static final String
CAMEL_SINK_AWS2ATHENA_COMPONENT_SECRET_KEY_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2ATHENA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-athena.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2ATHENA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the Athena client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in";
+ public static final Boolean
CAMEL_SINK_AWS2ATHENA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT =
false;
public static final String
CAMEL_SINK_AWS2ATHENA_COMPONENT_WAIT_TIMEOUT_CONF =
"camel.component.aws2-athena.waitTimeout";
public static final String
CAMEL_SINK_AWS2ATHENA_COMPONENT_WAIT_TIMEOUT_DOC = "Optional max wait time in
millis to wait for a successful query completion. See the section 'Waiting for
Query Completion and Retrying Failed Queries' to learn more.";
public static final Long
CAMEL_SINK_AWS2ATHENA_COMPONENT_WAIT_TIMEOUT_DEFAULT = 0L;
@@ -235,6 +241,7 @@ public class CamelAws2athenaSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_RESET_WAIT_TIMEOUT_ON_RETRY_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2ATHENA_ENDPOINT_RESET_WAIT_TIMEOUT_ON_RETRY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2ATHENA_ENDPOINT_RESET_WAIT_TIMEOUT_ON_RETRY_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_RETRY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2ATHENA_ENDPOINT_RETRY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_ENDPOINT_RETRY_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2ATHENA_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_ENDPOINT_SECRET_KEY_DOC);
+
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2ATHENA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2ATHENA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_WAIT_TIMEOUT_CONF,
ConfigDef.Type.LONG, CAMEL_SINK_AWS2ATHENA_ENDPOINT_WAIT_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_ENDPOINT_WAIT_TIMEOUT_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_WORK_GROUP_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2ATHENA_ENDPOINT_WORK_GROUP_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_ENDPOINT_WORK_GROUP_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_ENDPOINT_CLIENT_REQUEST_TOKEN_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2ATHENA_ENDPOINT_CLIENT_REQUEST_TOKEN_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2ATHENA_ENDPOINT_CLIENT_REQUEST_TOKEN_DOC);
@@ -263,6 +270,7 @@ public class CamelAws2athenaSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_RESET_WAIT_TIMEOUT_ON_RETRY_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2ATHENA_COMPONENT_RESET_WAIT_TIMEOUT_ON_RETRY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2ATHENA_COMPONENT_RESET_WAIT_TIMEOUT_ON_RETRY_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_RETRY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2ATHENA_COMPONENT_RETRY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_COMPONENT_RETRY_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2ATHENA_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_COMPONENT_SECRET_KEY_DOC);
+
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2ATHENA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2ATHENA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_WAIT_TIMEOUT_CONF,
ConfigDef.Type.LONG, CAMEL_SINK_AWS2ATHENA_COMPONENT_WAIT_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_COMPONENT_WAIT_TIMEOUT_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_WORK_GROUP_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2ATHENA_COMPONENT_WORK_GROUP_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2ATHENA_COMPONENT_WORK_GROUP_DOC);
conf.define(CAMEL_SINK_AWS2ATHENA_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2ATHENA_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2ATHENA_COMPONENT_AUTOWIRED_ENABLED_DOC);
diff --git
a/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
b/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
index 28b23b2..8a94f96 100644
---
a/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
+++
b/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
@@ -95,6 +95,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 client should expect
to load credentials through a default credentials provider or to expect static
credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.value": {
"name": "camel.sink.endpoint.value",
"description": "The metric value",
@@ -199,6 +206,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-cw.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-cw.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 client should expect
to load credentials through a default credentials provider or to expect static
credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-cw.value": {
"name": "camel.component.aws2-cw.value",
"description": "The metric value",
diff --git
a/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
b/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
index d99283c..4daf037 100644
---
a/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2cw.CamelAws2cwSinkConnector
----
-The camel-aws2-cw sink connector supports 33 options, which are listed below.
+The camel-aws2-cw sink connector supports 35 options, which are listed below.
@@ -44,6 +44,7 @@ The camel-aws2-cw sink connector supports 33 options, which
are listed below.
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.unit* | The metric unit | null | false | MEDIUM
| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the S3
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.value* | The metric value | null | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
@@ -60,6 +61,7 @@ The camel-aws2-cw sink connector supports 33 options, which
are listed below.
| *camel.component.aws2-cw.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-cw.unit* | The metric unit | null | false | MEDIUM
| *camel.component.aws2-cw.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
+| *camel.component.aws2-cw.useDefaultCredentials Provider* | Set whether the
S3 client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in. | false | false |
MEDIUM
| *camel.component.aws2-cw.value* | The metric value | null | false | MEDIUM
| *camel.component.aws2-cw.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.aws2-cw.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
diff --git
a/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
b/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
index 7f9efef..06780f5 100644
---
a/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
+++
b/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
@@ -63,6 +63,9 @@ public class CamelAws2cwSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2CW_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.sink.endpoint.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2CW_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option";
public static final String
CAMEL_SINK_AWS2CW_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2CW_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2CW_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the S3 client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2CW_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_VALUE_CONF =
"camel.sink.endpoint.value";
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_VALUE_DOC = "The
metric value";
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_VALUE_DEFAULT = null;
@@ -111,6 +114,9 @@ public class CamelAws2cwSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2CW_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-cw.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2CW_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option";
public static final String
CAMEL_SINK_AWS2CW_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2CW_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-cw.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2CW_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the S3 client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2CW_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2CW_COMPONENT_VALUE_CONF =
"camel.component.aws2-cw.value";
public static final String CAMEL_SINK_AWS2CW_COMPONENT_VALUE_DOC = "The
metric value";
public static final String CAMEL_SINK_AWS2CW_COMPONENT_VALUE_DEFAULT =
null;
@@ -149,6 +155,7 @@ public class CamelAws2cwSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2CW_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2CW_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_UNIT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2CW_ENDPOINT_UNIT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_ENDPOINT_UNIT_DOC);
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2CW_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2CW_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
+
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2CW_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2CW_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_VALUE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2CW_ENDPOINT_VALUE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_ENDPOINT_VALUE_DOC);
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2CW_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2CW_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2CW_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_ENDPOINT_SECRET_KEY_DOC);
@@ -165,6 +172,7 @@ public class CamelAws2cwSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2CW_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2CW_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_UNIT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2CW_COMPONENT_UNIT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_COMPONENT_UNIT_DOC);
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2CW_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2CW_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
+
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2CW_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2CW_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_VALUE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2CW_COMPONENT_VALUE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_COMPONENT_VALUE_DOC);
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2CW_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2CW_COMPONENT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2CW_COMPONENT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2CW_COMPONENT_ACCESS_KEY_DOC);
diff --git
a/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-sink.json
b/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-sink.json
index c16e57a..e54b6b5 100644
---
a/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-sink.json
+++
b/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-sink.json
@@ -17,13 +17,13 @@
},
"camel.sink.path.hosts": {
"name": "camel.sink.path.hosts",
- "description": "Hostname(s) cassansdra server(s).
Multiple hosts can be separated by comma.",
+ "description": "Hostname(s) Cassandra server(s).
Multiple hosts can be separated by comma.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.path.port": {
"name": "camel.sink.path.port",
- "description": "Port number of cassansdra server(s)",
+ "description": "Port number of Cassandra server(s)",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-source.json
b/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-source.json
index e2276f1..dc6bf84 100644
---
a/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-source.json
+++
b/connectors/camel-cql-kafka-connector/src/generated/resources/camel-cql-source.json
@@ -17,13 +17,13 @@
},
"camel.source.path.hosts": {
"name": "camel.source.path.hosts",
- "description": "Hostname(s) cassansdra server(s).
Multiple hosts can be separated by comma.",
+ "description": "Hostname(s) Cassandra server(s).
Multiple hosts can be separated by comma.",
"priority": "MEDIUM",
"required": "false"
},
"camel.source.path.port": {
"name": "camel.source.path.port",
- "description": "Port number of cassansdra server(s)",
+ "description": "Port number of Cassandra server(s)",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-sink-connector.adoc
b/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-sink-connector.adoc
index f7ec7a5..016d380 100644
---
a/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-sink-connector.adoc
+++
b/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-sink-connector.adoc
@@ -32,8 +32,8 @@ The camel-cql sink connector supports 17 options, which are
listed below.
|===
| Name | Description | Default | Required | Priority
| *camel.sink.path.beanRef* | beanRef is defined using bean:id | null | false
| MEDIUM
-| *camel.sink.path.hosts* | Hostname(s) cassansdra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
-| *camel.sink.path.port* | Port number of cassansdra server(s) | null | false
| MEDIUM
+| *camel.sink.path.hosts* | Hostname(s) Cassandra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
+| *camel.sink.path.port* | Port number of Cassandra server(s) | null | false |
MEDIUM
| *camel.sink.path.keyspace* | Keyspace to use | null | false | MEDIUM
| *camel.sink.endpoint.clusterName* | Cluster name | null | false | MEDIUM
| *camel.sink.endpoint.consistencyLevel* | Consistency level to use One of:
[ANY] [ONE] [TWO] [THREE] [QUORUM] [ALL] [LOCAL_ONE] [LOCAL_QUORUM]
[EACH_QUORUM] [SERIAL] [LOCAL_SERIAL] | null | false | MEDIUM
diff --git
a/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-source-connector.adoc
b/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-source-connector.adoc
index fbf7210..23ae1a6 100644
---
a/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-source-connector.adoc
+++
b/connectors/camel-cql-kafka-connector/src/main/docs/camel-cql-kafka-source-connector.adoc
@@ -32,8 +32,8 @@ The camel-cql source connector supports 35 options, which are
listed below.
|===
| Name | Description | Default | Required | Priority
| *camel.source.path.beanRef* | beanRef is defined using bean:id | null |
false | MEDIUM
-| *camel.source.path.hosts* | Hostname(s) cassansdra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
-| *camel.source.path.port* | Port number of cassansdra server(s) | null |
false | MEDIUM
+| *camel.source.path.hosts* | Hostname(s) Cassandra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
+| *camel.source.path.port* | Port number of Cassandra server(s) | null | false
| MEDIUM
| *camel.source.path.keyspace* | Keyspace to use | null | false | MEDIUM
| *camel.source.endpoint.clusterName* | Cluster name | null | false | MEDIUM
| *camel.source.endpoint.consistencyLevel* | Consistency level to use One of:
[ANY] [ONE] [TWO] [THREE] [QUORUM] [ALL] [LOCAL_ONE] [LOCAL_QUORUM]
[EACH_QUORUM] [SERIAL] [LOCAL_SERIAL] | null | false | MEDIUM
diff --git
a/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSinkConnectorConfig.java
b/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSinkConnectorConfig.java
index be1eca6..eb331a9 100644
---
a/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSinkConnectorConfig.java
+++
b/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSinkConnectorConfig.java
@@ -28,10 +28,10 @@ public class CamelCqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_CQL_PATH_BEAN_REF_DOC = "beanRef is
defined using bean:id";
public static final String CAMEL_SINK_CQL_PATH_BEAN_REF_DEFAULT = null;
public static final String CAMEL_SINK_CQL_PATH_HOSTS_CONF =
"camel.sink.path.hosts";
- public static final String CAMEL_SINK_CQL_PATH_HOSTS_DOC = "Hostname(s)
cassansdra server(s). Multiple hosts can be separated by comma.";
+ public static final String CAMEL_SINK_CQL_PATH_HOSTS_DOC = "Hostname(s)
Cassandra server(s). Multiple hosts can be separated by comma.";
public static final String CAMEL_SINK_CQL_PATH_HOSTS_DEFAULT = null;
public static final String CAMEL_SINK_CQL_PATH_PORT_CONF =
"camel.sink.path.port";
- public static final String CAMEL_SINK_CQL_PATH_PORT_DOC = "Port number of
cassansdra server(s)";
+ public static final String CAMEL_SINK_CQL_PATH_PORT_DOC = "Port number of
Cassandra server(s)";
public static final String CAMEL_SINK_CQL_PATH_PORT_DEFAULT = null;
public static final String CAMEL_SINK_CQL_PATH_KEYSPACE_CONF =
"camel.sink.path.keyspace";
public static final String CAMEL_SINK_CQL_PATH_KEYSPACE_DOC = "Keyspace to
use";
diff --git
a/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSourceConnectorConfig.java
b/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSourceConnectorConfig.java
index 71c3cf5..b70aea2 100644
---
a/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSourceConnectorConfig.java
+++
b/connectors/camel-cql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cql/CamelCqlSourceConnectorConfig.java
@@ -28,10 +28,10 @@ public class CamelCqlSourceConnectorConfig extends
CamelSourceConnectorConfig {
public static final String CAMEL_SOURCE_CQL_PATH_BEAN_REF_DOC = "beanRef
is defined using bean:id";
public static final String CAMEL_SOURCE_CQL_PATH_BEAN_REF_DEFAULT = null;
public static final String CAMEL_SOURCE_CQL_PATH_HOSTS_CONF =
"camel.source.path.hosts";
- public static final String CAMEL_SOURCE_CQL_PATH_HOSTS_DOC = "Hostname(s)
cassansdra server(s). Multiple hosts can be separated by comma.";
+ public static final String CAMEL_SOURCE_CQL_PATH_HOSTS_DOC = "Hostname(s)
Cassandra server(s). Multiple hosts can be separated by comma.";
public static final String CAMEL_SOURCE_CQL_PATH_HOSTS_DEFAULT = null;
public static final String CAMEL_SOURCE_CQL_PATH_PORT_CONF =
"camel.source.path.port";
- public static final String CAMEL_SOURCE_CQL_PATH_PORT_DOC = "Port number
of cassansdra server(s)";
+ public static final String CAMEL_SOURCE_CQL_PATH_PORT_DOC = "Port number
of Cassandra server(s)";
public static final String CAMEL_SOURCE_CQL_PATH_PORT_DEFAULT = null;
public static final String CAMEL_SOURCE_CQL_PATH_KEYSPACE_CONF =
"camel.source.path.keyspace";
public static final String CAMEL_SOURCE_CQL_PATH_KEYSPACE_DOC = "Keyspace
to use";
diff --git
a/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json
b/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json
index faeaca3..9369114 100644
---
a/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json
+++
b/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json
@@ -21,6 +21,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.autoCommit": {
+ "name": "camel.sink.endpoint.autoCommit",
+ "description": "If true, each producer operation will
be committed automatically",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.connectionTimeout": {
"name": "camel.sink.endpoint.connectionTimeout",
"description": "connectionTimeout on the underlying
HttpConnectionManager",
diff --git
a/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc
b/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc
index 7d95c36..3f2aff1 100644
---
a/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc
+++
b/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.solr.CamelSolrSinkConnector
----
-The camel-solr sink connector supports 18 options, which are listed below.
+The camel-solr sink connector supports 19 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-solr sink connector supports 18 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.url* | Hostname and port for the solr server | null | true
| HIGH
| *camel.sink.endpoint.allowCompression* | Server side must support gzip or
deflate for this to have any effect | null | false | MEDIUM
+| *camel.sink.endpoint.autoCommit* | If true, each producer operation will be
committed automatically | false | false | MEDIUM
| *camel.sink.endpoint.connectionTimeout* | connectionTimeout on the
underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost
on the underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.followRedirects* | indicates whether redirects are used
to get to the Solr server | null | false | MEDIUM
diff --git
a/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java
b/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java
index 6951938..e8275ca 100644
---
a/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java
+++
b/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java
@@ -30,6 +30,9 @@ public class CamelSolrSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_CONF
= "camel.sink.endpoint.allowCompression";
public static final String CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_DOC
= "Server side must support gzip or deflate for this to have any effect";
public static final String
CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_DEFAULT = null;
+ public static final String CAMEL_SINK_SOLR_ENDPOINT_AUTO_COMMIT_CONF =
"camel.sink.endpoint.autoCommit";
+ public static final String CAMEL_SINK_SOLR_ENDPOINT_AUTO_COMMIT_DOC = "If
true, each producer operation will be committed automatically";
+ public static final Boolean CAMEL_SINK_SOLR_ENDPOINT_AUTO_COMMIT_DEFAULT =
false;
public static final String
CAMEL_SINK_SOLR_ENDPOINT_CONNECTION_TIMEOUT_CONF =
"camel.sink.endpoint.connectionTimeout";
public static final String CAMEL_SINK_SOLR_ENDPOINT_CONNECTION_TIMEOUT_DOC
= "connectionTimeout on the underlying HttpConnectionManager";
public static final String
CAMEL_SINK_SOLR_ENDPOINT_CONNECTION_TIMEOUT_DEFAULT = null;
@@ -93,6 +96,7 @@ public class CamelSolrSinkConnectorConfig extends
CamelSinkConnectorConfig {
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_SOLR_PATH_URL_CONF, ConfigDef.Type.STRING,
CAMEL_SINK_SOLR_PATH_URL_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SINK_SOLR_PATH_URL_DOC);
conf.define(CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_DOC);
+ conf.define(CAMEL_SINK_SOLR_ENDPOINT_AUTO_COMMIT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SOLR_ENDPOINT_AUTO_COMMIT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLR_ENDPOINT_AUTO_COMMIT_DOC);
conf.define(CAMEL_SINK_SOLR_ENDPOINT_CONNECTION_TIMEOUT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLR_ENDPOINT_CONNECTION_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLR_ENDPOINT_CONNECTION_TIMEOUT_DOC);
conf.define(CAMEL_SINK_SOLR_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SOLR_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SOLR_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DOC);
conf.define(CAMEL_SINK_SOLR_ENDPOINT_FOLLOW_REDIRECTS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLR_ENDPOINT_FOLLOW_REDIRECTS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLR_ENDPOINT_FOLLOW_REDIRECTS_DOC);
diff --git
a/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json
b/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json
index 551bd64..508c2ec 100644
---
a/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json
+++
b/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json
@@ -21,6 +21,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.autoCommit": {
+ "name": "camel.sink.endpoint.autoCommit",
+ "description": "If true, each producer operation will
be committed automatically",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.connectionTimeout": {
"name": "camel.sink.endpoint.connectionTimeout",
"description": "connectionTimeout on the underlying
HttpConnectionManager",
diff --git
a/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc
b/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc
index 765b2a7..9a3849b 100644
---
a/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc
+++
b/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.solrcloud.CamelSolrcloudSinkConn
----
-The camel-solrCloud sink connector supports 18 options, which are listed below.
+The camel-solrCloud sink connector supports 19 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-solrCloud sink connector supports 18 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.url* | Hostname and port for the solr server | null | true
| HIGH
| *camel.sink.endpoint.allowCompression* | Server side must support gzip or
deflate for this to have any effect | null | false | MEDIUM
+| *camel.sink.endpoint.autoCommit* | If true, each producer operation will be
committed automatically | false | false | MEDIUM
| *camel.sink.endpoint.connectionTimeout* | connectionTimeout on the
underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost
on the underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.followRedirects* | indicates whether redirects are used
to get to the Solr server | null | false | MEDIUM
diff --git
a/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java
b/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java
index 34b3f78..c76b8be 100644
---
a/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java
+++
b/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java
@@ -32,6 +32,9 @@ public class CamelSolrcloudSinkConnectorConfig
public static final String
CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_CONF =
"camel.sink.endpoint.allowCompression";
public static final String
CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_DOC = "Server side must support
gzip or deflate for this to have any effect";
public static final String
CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_DEFAULT = null;
+ public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_AUTO_COMMIT_CONF
= "camel.sink.endpoint.autoCommit";
+ public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_AUTO_COMMIT_DOC =
"If true, each producer operation will be committed automatically";
+ public static final Boolean
CAMEL_SINK_SOLRCLOUD_ENDPOINT_AUTO_COMMIT_DEFAULT = false;
public static final String
CAMEL_SINK_SOLRCLOUD_ENDPOINT_CONNECTION_TIMEOUT_CONF =
"camel.sink.endpoint.connectionTimeout";
public static final String
CAMEL_SINK_SOLRCLOUD_ENDPOINT_CONNECTION_TIMEOUT_DOC = "connectionTimeout on
the underlying HttpConnectionManager";
public static final String
CAMEL_SINK_SOLRCLOUD_ENDPOINT_CONNECTION_TIMEOUT_DEFAULT = null;
@@ -95,6 +98,7 @@ public class CamelSolrcloudSinkConnectorConfig
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_SOLRCLOUD_PATH_URL_CONF, ConfigDef.Type.STRING,
CAMEL_SINK_SOLRCLOUD_PATH_URL_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SINK_SOLRCLOUD_PATH_URL_DOC);
conf.define(CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_DOC);
+ conf.define(CAMEL_SINK_SOLRCLOUD_ENDPOINT_AUTO_COMMIT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SOLRCLOUD_ENDPOINT_AUTO_COMMIT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLRCLOUD_ENDPOINT_AUTO_COMMIT_DOC);
conf.define(CAMEL_SINK_SOLRCLOUD_ENDPOINT_CONNECTION_TIMEOUT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SOLRCLOUD_ENDPOINT_CONNECTION_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SOLRCLOUD_ENDPOINT_CONNECTION_TIMEOUT_DOC);
conf.define(CAMEL_SINK_SOLRCLOUD_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SOLRCLOUD_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SOLRCLOUD_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DOC);
conf.define(CAMEL_SINK_SOLRCLOUD_ENDPOINT_FOLLOW_REDIRECTS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLRCLOUD_ENDPOINT_FOLLOW_REDIRECTS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SOLRCLOUD_ENDPOINT_FOLLOW_REDIRECTS_DOC);
diff --git
a/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json
b/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json
index f15e4c2..93ad59e 100644
---
a/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json
+++
b/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json
@@ -21,6 +21,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.autoCommit": {
+ "name": "camel.sink.endpoint.autoCommit",
+ "description": "If true, each producer operation will
be committed automatically",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.connectionTimeout": {
"name": "camel.sink.endpoint.connectionTimeout",
"description": "connectionTimeout on the underlying
HttpConnectionManager",
diff --git
a/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc
b/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc
index 2fdc077..659a831 100644
---
a/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc
+++
b/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.solrs.CamelSolrsSinkConnector
----
-The camel-solrs sink connector supports 18 options, which are listed below.
+The camel-solrs sink connector supports 19 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-solrs sink connector supports 18 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.url* | Hostname and port for the solr server | null | true
| HIGH
| *camel.sink.endpoint.allowCompression* | Server side must support gzip or
deflate for this to have any effect | null | false | MEDIUM
+| *camel.sink.endpoint.autoCommit* | If true, each producer operation will be
committed automatically | false | false | MEDIUM
| *camel.sink.endpoint.connectionTimeout* | connectionTimeout on the
underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost
on the underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.followRedirects* | indicates whether redirects are used
to get to the Solr server | null | false | MEDIUM
diff --git
a/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java
b/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java
index bf2653b..0e82d27 100644
---
a/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java
+++
b/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java
@@ -30,6 +30,9 @@ public class CamelSolrsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_CONF =
"camel.sink.endpoint.allowCompression";
public static final String CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_DOC
= "Server side must support gzip or deflate for this to have any effect";
public static final String
CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_DEFAULT = null;
+ public static final String CAMEL_SINK_SOLRS_ENDPOINT_AUTO_COMMIT_CONF =
"camel.sink.endpoint.autoCommit";
+ public static final String CAMEL_SINK_SOLRS_ENDPOINT_AUTO_COMMIT_DOC = "If
true, each producer operation will be committed automatically";
+ public static final Boolean CAMEL_SINK_SOLRS_ENDPOINT_AUTO_COMMIT_DEFAULT
= false;
public static final String
CAMEL_SINK_SOLRS_ENDPOINT_CONNECTION_TIMEOUT_CONF =
"camel.sink.endpoint.connectionTimeout";
public static final String
CAMEL_SINK_SOLRS_ENDPOINT_CONNECTION_TIMEOUT_DOC = "connectionTimeout on the
underlying HttpConnectionManager";
public static final String
CAMEL_SINK_SOLRS_ENDPOINT_CONNECTION_TIMEOUT_DEFAULT = null;
@@ -93,6 +96,7 @@ public class CamelSolrsSinkConnectorConfig extends
CamelSinkConnectorConfig {
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_SOLRS_PATH_URL_CONF, ConfigDef.Type.STRING,
CAMEL_SINK_SOLRS_PATH_URL_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SINK_SOLRS_PATH_URL_DOC);
conf.define(CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_DOC);
+ conf.define(CAMEL_SINK_SOLRS_ENDPOINT_AUTO_COMMIT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SOLRS_ENDPOINT_AUTO_COMMIT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLRS_ENDPOINT_AUTO_COMMIT_DOC);
conf.define(CAMEL_SINK_SOLRS_ENDPOINT_CONNECTION_TIMEOUT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLRS_ENDPOINT_CONNECTION_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLRS_ENDPOINT_CONNECTION_TIMEOUT_DOC);
conf.define(CAMEL_SINK_SOLRS_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SOLRS_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SOLRS_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DOC);
conf.define(CAMEL_SINK_SOLRS_ENDPOINT_FOLLOW_REDIRECTS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SOLRS_ENDPOINT_FOLLOW_REDIRECTS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SOLRS_ENDPOINT_FOLLOW_REDIRECTS_DOC);
diff --git
a/connectors/camel-splunk-hec-kafka-connector/src/generated/resources/camel-splunk-hec-sink.json
b/connectors/camel-splunk-hec-kafka-connector/src/generated/resources/camel-splunk-hec-sink.json
index c148edc..d824958 100644
---
a/connectors/camel-splunk-hec-kafka-connector/src/generated/resources/camel-splunk-hec-sink.json
+++
b/connectors/camel-splunk-hec-kafka-connector/src/generated/resources/camel-splunk-hec-sink.json
@@ -21,6 +21,20 @@
"priority": "HIGH",
"required": "true"
},
+ "camel.sink.endpoint.bodyOnly": {
+ "name": "camel.sink.endpoint.bodyOnly",
+ "description": "Send only the message body",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.headersOnly": {
+ "name": "camel.sink.endpoint.headersOnly",
+ "description": "Send only message headers",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.host": {
"name": "camel.sink.endpoint.host",
"description": "Splunk host.",
diff --git
a/connectors/camel-splunk-hec-kafka-connector/src/main/docs/camel-splunk-hec-kafka-sink-connector.adoc
b/connectors/camel-splunk-hec-kafka-connector/src/main/docs/camel-splunk-hec-kafka-sink-connector.adoc
index f30042a..c5cbd3a 100644
---
a/connectors/camel-splunk-hec-kafka-connector/src/main/docs/camel-splunk-hec-kafka-sink-connector.adoc
+++
b/connectors/camel-splunk-hec-kafka-connector/src/main/docs/camel-splunk-hec-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.splunkhec.CamelSplunkhecSinkConn
----
-The camel-splunk-hec sink connector supports 11 options, which are listed
below.
+The camel-splunk-hec sink connector supports 13 options, which are listed
below.
@@ -33,6 +33,8 @@ The camel-splunk-hec sink connector supports 11 options,
which are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.splunkURL* | Splunk Host URL | null | true | HIGH
| *camel.sink.path.token* | Splunk authorization token | null | true | HIGH
+| *camel.sink.endpoint.bodyOnly* | Send only the message body | false | false
| MEDIUM
+| *camel.sink.endpoint.headersOnly* | Send only message headers | false |
false | MEDIUM
| *camel.sink.endpoint.host* | Splunk host. | null | false | MEDIUM
| *camel.sink.endpoint.index* | Splunk index to write to | "camel" | 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 [...]
diff --git
a/connectors/camel-splunk-hec-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/splunkhec/CamelSplunkhecSinkConnectorConfig.java
b/connectors/camel-splunk-hec-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/splunkhec/CamelSplunkhecSinkConnectorConfig.java
index db13e48..db8a01c 100644
---
a/connectors/camel-splunk-hec-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/splunkhec/CamelSplunkhecSinkConnectorConfig.java
+++
b/connectors/camel-splunk-hec-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/splunkhec/CamelSplunkhecSinkConnectorConfig.java
@@ -32,6 +32,12 @@ public class CamelSplunkhecSinkConnectorConfig
public static final String CAMEL_SINK_SPLUNKHEC_PATH_TOKEN_CONF =
"camel.sink.path.token";
public static final String CAMEL_SINK_SPLUNKHEC_PATH_TOKEN_DOC = "Splunk
authorization token";
public static final String CAMEL_SINK_SPLUNKHEC_PATH_TOKEN_DEFAULT = null;
+ public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_BODY_ONLY_CONF =
"camel.sink.endpoint.bodyOnly";
+ public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_BODY_ONLY_DOC =
"Send only the message body";
+ public static final Boolean
CAMEL_SINK_SPLUNKHEC_ENDPOINT_BODY_ONLY_DEFAULT = false;
+ public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_HEADERS_ONLY_CONF
= "camel.sink.endpoint.headersOnly";
+ public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_HEADERS_ONLY_DOC
= "Send only message headers";
+ public static final Boolean
CAMEL_SINK_SPLUNKHEC_ENDPOINT_HEADERS_ONLY_DEFAULT = false;
public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_HOST_CONF =
"camel.sink.endpoint.host";
public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_HOST_DOC =
"Splunk host.";
public static final String CAMEL_SINK_SPLUNKHEC_ENDPOINT_HOST_DEFAULT =
null;
@@ -74,6 +80,8 @@ public class CamelSplunkhecSinkConnectorConfig
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_SPLUNKHEC_PATH_SPLUNK_URLCONF,
ConfigDef.Type.STRING, CAMEL_SINK_SPLUNKHEC_PATH_SPLUNK_URLDEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_SPLUNKHEC_PATH_SPLUNK_URLDOC);
conf.define(CAMEL_SINK_SPLUNKHEC_PATH_TOKEN_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SPLUNKHEC_PATH_TOKEN_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_SPLUNKHEC_PATH_TOKEN_DOC);
+ conf.define(CAMEL_SINK_SPLUNKHEC_ENDPOINT_BODY_ONLY_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SPLUNKHEC_ENDPOINT_BODY_ONLY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SPLUNKHEC_ENDPOINT_BODY_ONLY_DOC);
+ conf.define(CAMEL_SINK_SPLUNKHEC_ENDPOINT_HEADERS_ONLY_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SPLUNKHEC_ENDPOINT_HEADERS_ONLY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SPLUNKHEC_ENDPOINT_HEADERS_ONLY_DOC);
conf.define(CAMEL_SINK_SPLUNKHEC_ENDPOINT_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SPLUNKHEC_ENDPOINT_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SPLUNKHEC_ENDPOINT_HOST_DOC);
conf.define(CAMEL_SINK_SPLUNKHEC_ENDPOINT_INDEX_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SPLUNKHEC_ENDPOINT_INDEX_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SPLUNKHEC_ENDPOINT_INDEX_DOC);
conf.define(CAMEL_SINK_SPLUNKHEC_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_SPLUNKHEC_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SPLUNKHEC_ENDPOINT_LAZY_START_PRODUCER_DOC);
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-sink.json
b/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-sink.json
index f3b6c2f..f63a946 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-sink.json
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-sink.json
@@ -11,7 +11,7 @@
"properties": {
"camel.sink.path.timelineType": {
"name": "camel.sink.path.timelineType",
- "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN]",
+ "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN]",
"priority": "HIGH",
"required": "true",
"enum": [
@@ -20,9 +20,16 @@
"USER",
"MENTIONS",
"RETWEETSOFME",
+ "LIST",
"UNKNOWN"
]
},
+ "camel.sink.endpoint.list": {
+ "name": "camel.sink.endpoint.list",
+ "description": "The list name when using
timelineType=list",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.user": {
"name": "camel.sink.endpoint.user",
"description": "The username when using
timelineType=user",
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-source.json
b/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-source.json
index f2464ea..db78afa 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-source.json
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/generated/resources/camel-twitter-timeline-source.json
@@ -11,7 +11,7 @@
"properties": {
"camel.source.path.timelineType": {
"name": "camel.source.path.timelineType",
- "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN]",
+ "description": "The timeline type to produce\/consume.
One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN]",
"priority": "HIGH",
"required": "true",
"enum": [
@@ -20,9 +20,16 @@
"USER",
"MENTIONS",
"RETWEETSOFME",
+ "LIST",
"UNKNOWN"
]
},
+ "camel.source.endpoint.list": {
+ "name": "camel.source.endpoint.list",
+ "description": "The list name when using
timelineType=list",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.user": {
"name": "camel.source.endpoint.user",
"description": "The username when using
timelineType=user",
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-sink-connector.adoc
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-sink-connector.adoc
index 83ff9ea..c952438 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-sink-connector.adoc
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-sink-connector.adoc
@@ -24,14 +24,15 @@
connector.class=org.apache.camel.kafkaconnector.twittertimeline.CamelTwittertime
----
-The camel-twitter-timeline sink connector supports 21 options, which are
listed below.
+The camel-twitter-timeline sink connector supports 22 options, which are
listed below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN] | null | true |
HIGH
+| *camel.sink.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN] | null |
true | HIGH
+| *camel.sink.endpoint.list* | The list name when using timelineType=list |
null | false | MEDIUM
| *camel.sink.endpoint.user* | The username when using timelineType=user |
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.httpProxyHost* | The http proxy host which can be used
for the camel-twitter. Can also be configured on the TwitterComponent level
instead. | null | false | MEDIUM
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-source-connector.adoc
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-source-connector.adoc
index 9ce8e99..9f9806f 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-source-connector.adoc
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/camel-twitter-timeline-kafka-source-connector.adoc
@@ -24,14 +24,15 @@
connector.class=org.apache.camel.kafkaconnector.twittertimeline.CamelTwittertime
----
-The camel-twitter-timeline source connector supports 53 options, which are
listed below.
+The camel-twitter-timeline source connector supports 54 options, which are
listed below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.source.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN] | null | true |
HIGH
+| *camel.source.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN] | null |
true | HIGH
+| *camel.source.endpoint.list* | The list name when using timelineType=list |
null | false | MEDIUM
| *camel.source.endpoint.user* | The username when using timelineType=user |
null | false | MEDIUM
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.source.endpoint.sendEmptyMessageWhenIdle* | If the polling consumer
did not poll any files, you can enable this option to send an empty message (no
body) instead. | false | false | MEDIUM
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSinkConnector.properties
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSinkConnector.properties
index 88c4698..8b726ea 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSinkConnector.properties
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSinkConnector.properties
@@ -28,6 +28,6 @@ topics=
# mandatory properties (for a complete properties list see the connector
documentation):
-# The timeline type to produce/consume. One of: [PUBLIC] [HOME] [USER]
[MENTIONS] [RETWEETSOFME] [UNKNOWN]
+# The timeline type to produce/consume. One of: [PUBLIC] [HOME] [USER]
[MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN]
camel.sink.path.timelineType=
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSourceConnector.properties
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSourceConnector.properties
index af49fdc..9e5837d 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSourceConnector.properties
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/main/docs/examples/CamelTwittertimelineSourceConnector.properties
@@ -28,6 +28,6 @@ topics=
# mandatory properties (for a complete properties list see the connector
documentation):
-# The timeline type to produce/consume. One of: [PUBLIC] [HOME] [USER]
[MENTIONS] [RETWEETSOFME] [UNKNOWN]
+# The timeline type to produce/consume. One of: [PUBLIC] [HOME] [USER]
[MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN]
camel.source.path.timelineType=
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSinkConnectorConfig.java
b/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSinkConnectorConfig.java
index fa2d5b4..1df250d 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSinkConnectorConfig.java
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSinkConnectorConfig.java
@@ -27,8 +27,11 @@ public class CamelTwittertimelineSinkConnectorConfig
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_CONF =
"camel.sink.path.timelineType";
- public static final String
CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DOC = "The timeline type to
produce/consume. One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME]
[UNKNOWN]";
+ public static final String
CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DOC = "The timeline type to
produce/consume. One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME]
[LIST] [UNKNOWN]";
public static final String
CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DEFAULT = null;
+ public static final String CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LIST_CONF =
"camel.sink.endpoint.list";
+ public static final String CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LIST_DOC =
"The list name when using timelineType=list";
+ public static final String
CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LIST_DEFAULT = null;
public static final String CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_USER_CONF =
"camel.sink.endpoint.user";
public static final String CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_USER_DOC =
"The username when using timelineType=user";
public static final String
CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_USER_DEFAULT = null;
@@ -104,6 +107,7 @@ public class CamelTwittertimelineSinkConnectorConfig
public static ConfigDef conf() {
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DOC);
+ conf.define(CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LIST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LIST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LIST_DOC);
conf.define(CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_USER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_USER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_USER_DOC);
conf.define(CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_HTTP_PROXY_HOST_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_HTTP_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_TWITTERTIMELINE_ENDPOINT_HTTP_PROXY_HOST_DOC);
diff --git
a/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSourceConnectorConfig.java
b/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSourceConnectorConfig.java
index 465fa3e..15df12a 100644
---
a/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSourceConnectorConfig.java
+++
b/connectors/camel-twitter-timeline-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twittertimeline/CamelTwittertimelineSourceConnectorConfig.java
@@ -27,8 +27,11 @@ public class CamelTwittertimelineSourceConnectorConfig
CamelSourceConnectorConfig {
public static final String
CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_CONF =
"camel.source.path.timelineType";
- public static final String
CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DOC = "The timeline type to
produce/consume. One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME]
[UNKNOWN]";
+ public static final String
CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DOC = "The timeline type to
produce/consume. One of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME]
[LIST] [UNKNOWN]";
public static final String
CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DEFAULT = null;
+ public static final String CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_LIST_CONF
= "camel.source.endpoint.list";
+ public static final String CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_LIST_DOC
= "The list name when using timelineType=list";
+ public static final String
CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_LIST_DEFAULT = null;
public static final String CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_USER_CONF
= "camel.source.endpoint.user";
public static final String CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_USER_DOC
= "The username when using timelineType=user";
public static final String
CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_USER_DEFAULT = null;
@@ -200,6 +203,7 @@ public class CamelTwittertimelineSourceConnectorConfig
public static ConfigDef conf() {
ConfigDef conf = new ConfigDef(CamelSourceConnectorConfig.conf());
conf.define(CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SOURCE_TWITTERTIMELINE_PATH_TIMELINE_TYPE_DOC);
+ conf.define(CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_LIST_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_LIST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_LIST_DOC);
conf.define(CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_USER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_USER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_USER_DOC);
conf.define(CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_SEND_EMPTY_MESSAGE_WHEN_IDLE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_SEND_EMPTY_MESSAGE_WHEN_IDLE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_TWITTERTIMELINE_ENDPOINT_SEND_EMPTY_MESSAGE_WHEN_IDLE_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-athena-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-athena-kafka-sink-connector.adoc
index c4153ec..ef2eef1 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-athena-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-athena-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2athena.CamelAws2athenaSinkCo
----
-The camel-aws2-athena sink connector supports 57 options, which are listed
below.
+The camel-aws2-athena sink connector supports 59 options, which are listed
below.
@@ -56,6 +56,7 @@ The camel-aws2-athena sink connector supports 57 options,
which are listed below
| *camel.sink.endpoint.resetWaitTimeoutOnRetry* | Reset the waitTimeout
countdown in the event of a query retry. If set to true, potential max time
spent waiting for queries is equal to waitTimeout x maxAttempts. See the
section 'Waiting for Query Completion and Retrying Failed Queries' to learn
more. | true | false | MEDIUM
| *camel.sink.endpoint.retry* | Optional comma separated list of error types
to retry the query for. Use 'retryable' to retry all retryable failure
conditions (e.g. generic errors and resources exhausted), 'generic' to retry
'GENERIC_INTERNAL_ERROR' failures, 'exhausted' to retry queries that have
exhausted resource limits, 'always' to always retry regardless of failure
condition, or 'never' or null to never retry (default). See the section
'Waiting for Query Completion and Retrying Fail [...]
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key. | null | false |
MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the Athena
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in | false | false | MEDIUM
| *camel.sink.endpoint.waitTimeout* | Optional max wait time in millis to wait
for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more. | 0L | false | MEDIUM
| *camel.sink.endpoint.workGroup* | The workgroup to use for running the
query. | null | false | MEDIUM
| *camel.sink.endpoint.clientRequestToken* | A unique string to ensure issues
queries are idempotent. It is unlikely you will need to set this. | null |
false | MEDIUM
@@ -84,6 +85,7 @@ The camel-aws2-athena sink connector supports 57 options,
which are listed below
| *camel.component.aws2-athena.resetWaitTimeoutOn Retry* | Reset the
waitTimeout countdown in the event of a query retry. If set to true, potential
max time spent waiting for queries is equal to waitTimeout x maxAttempts. See
the section 'Waiting for Query Completion and Retrying Failed Queries' to learn
more. | true | false | MEDIUM
| *camel.component.aws2-athena.retry* | Optional comma separated list of error
types to retry the query for. Use 'retryable' to retry all retryable failure
conditions (e.g. generic errors and resources exhausted), 'generic' to retry
'GENERIC_INTERNAL_ERROR' failures, 'exhausted' to retry queries that have
exhausted resource limits, 'always' to always retry regardless of failure
condition, or 'never' or null to never retry (default). See the section
'Waiting for Query Completion and Retry [...]
| *camel.component.aws2-athena.secretKey* | Amazon AWS Secret Key. | null |
false | MEDIUM
+| *camel.component.aws2-athena.useDefaultCredentials Provider* | Set whether
the Athena client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in | false |
false | MEDIUM
| *camel.component.aws2-athena.waitTimeout* | Optional max wait time in millis
to wait for a successful query completion. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to learn more. | 0L | false | MEDIUM
| *camel.component.aws2-athena.workGroup* | The workgroup to use for running
the query. | null | false | MEDIUM
| *camel.component.aws2-athena.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
index d99283c..4daf037 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2cw.CamelAws2cwSinkConnector
----
-The camel-aws2-cw sink connector supports 33 options, which are listed below.
+The camel-aws2-cw sink connector supports 35 options, which are listed below.
@@ -44,6 +44,7 @@ The camel-aws2-cw sink connector supports 33 options, which
are listed below.
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.unit* | The metric unit | null | false | MEDIUM
| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the S3
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.value* | The metric value | null | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
@@ -60,6 +61,7 @@ The camel-aws2-cw sink connector supports 33 options, which
are listed below.
| *camel.component.aws2-cw.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-cw.unit* | The metric unit | null | false | MEDIUM
| *camel.component.aws2-cw.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
+| *camel.component.aws2-cw.useDefaultCredentials Provider* | Set whether the
S3 client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in. | false | false |
MEDIUM
| *camel.component.aws2-cw.value* | The metric value | null | false | MEDIUM
| *camel.component.aws2-cw.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.aws2-cw.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-cql-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-cql-kafka-sink-connector.adoc
index f7ec7a5..016d380 100644
--- a/docs/modules/ROOT/pages/connectors/camel-cql-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-cql-kafka-sink-connector.adoc
@@ -32,8 +32,8 @@ The camel-cql sink connector supports 17 options, which are
listed below.
|===
| Name | Description | Default | Required | Priority
| *camel.sink.path.beanRef* | beanRef is defined using bean:id | null | false
| MEDIUM
-| *camel.sink.path.hosts* | Hostname(s) cassansdra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
-| *camel.sink.path.port* | Port number of cassansdra server(s) | null | false
| MEDIUM
+| *camel.sink.path.hosts* | Hostname(s) Cassandra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
+| *camel.sink.path.port* | Port number of Cassandra server(s) | null | false |
MEDIUM
| *camel.sink.path.keyspace* | Keyspace to use | null | false | MEDIUM
| *camel.sink.endpoint.clusterName* | Cluster name | null | false | MEDIUM
| *camel.sink.endpoint.consistencyLevel* | Consistency level to use One of:
[ANY] [ONE] [TWO] [THREE] [QUORUM] [ALL] [LOCAL_ONE] [LOCAL_QUORUM]
[EACH_QUORUM] [SERIAL] [LOCAL_SERIAL] | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-cql-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-cql-kafka-source-connector.adoc
index fbf7210..23ae1a6 100644
--- a/docs/modules/ROOT/pages/connectors/camel-cql-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-cql-kafka-source-connector.adoc
@@ -32,8 +32,8 @@ The camel-cql source connector supports 35 options, which are
listed below.
|===
| Name | Description | Default | Required | Priority
| *camel.source.path.beanRef* | beanRef is defined using bean:id | null |
false | MEDIUM
-| *camel.source.path.hosts* | Hostname(s) cassansdra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
-| *camel.source.path.port* | Port number of cassansdra server(s) | null |
false | MEDIUM
+| *camel.source.path.hosts* | Hostname(s) Cassandra server(s). Multiple hosts
can be separated by comma. | null | false | MEDIUM
+| *camel.source.path.port* | Port number of Cassandra server(s) | null | false
| MEDIUM
| *camel.source.path.keyspace* | Keyspace to use | null | false | MEDIUM
| *camel.source.endpoint.clusterName* | Cluster name | null | false | MEDIUM
| *camel.source.endpoint.consistencyLevel* | Consistency level to use One of:
[ANY] [ONE] [TWO] [THREE] [QUORUM] [ALL] [LOCAL_ONE] [LOCAL_QUORUM]
[EACH_QUORUM] [SERIAL] [LOCAL_SERIAL] | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc
index 7d95c36..3f2aff1 100644
--- a/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.solr.CamelSolrSinkConnector
----
-The camel-solr sink connector supports 18 options, which are listed below.
+The camel-solr sink connector supports 19 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-solr sink connector supports 18 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.url* | Hostname and port for the solr server | null | true
| HIGH
| *camel.sink.endpoint.allowCompression* | Server side must support gzip or
deflate for this to have any effect | null | false | MEDIUM
+| *camel.sink.endpoint.autoCommit* | If true, each producer operation will be
committed automatically | false | false | MEDIUM
| *camel.sink.endpoint.connectionTimeout* | connectionTimeout on the
underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost
on the underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.followRedirects* | indicates whether redirects are used
to get to the Solr server | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc
index 765b2a7..9a3849b 100644
---
a/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.solrcloud.CamelSolrcloudSinkConn
----
-The camel-solrCloud sink connector supports 18 options, which are listed below.
+The camel-solrCloud sink connector supports 19 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-solrCloud sink connector supports 18 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.url* | Hostname and port for the solr server | null | true
| HIGH
| *camel.sink.endpoint.allowCompression* | Server side must support gzip or
deflate for this to have any effect | null | false | MEDIUM
+| *camel.sink.endpoint.autoCommit* | If true, each producer operation will be
committed automatically | false | false | MEDIUM
| *camel.sink.endpoint.connectionTimeout* | connectionTimeout on the
underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost
on the underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.followRedirects* | indicates whether redirects are used
to get to the Solr server | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc
index 2fdc077..659a831 100644
--- a/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.solrs.CamelSolrsSinkConnector
----
-The camel-solrs sink connector supports 18 options, which are listed below.
+The camel-solrs sink connector supports 19 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-solrs sink connector supports 18 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.url* | Hostname and port for the solr server | null | true
| HIGH
| *camel.sink.endpoint.allowCompression* | Server side must support gzip or
deflate for this to have any effect | null | false | MEDIUM
+| *camel.sink.endpoint.autoCommit* | If true, each producer operation will be
committed automatically | false | false | MEDIUM
| *camel.sink.endpoint.connectionTimeout* | connectionTimeout on the
underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost
on the underlying HttpConnectionManager | null | false | MEDIUM
| *camel.sink.endpoint.followRedirects* | indicates whether redirects are used
to get to the Solr server | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-splunk-hec-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-splunk-hec-kafka-sink-connector.adoc
index f30042a..c5cbd3a 100644
---
a/docs/modules/ROOT/pages/connectors/camel-splunk-hec-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-splunk-hec-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.splunkhec.CamelSplunkhecSinkConn
----
-The camel-splunk-hec sink connector supports 11 options, which are listed
below.
+The camel-splunk-hec sink connector supports 13 options, which are listed
below.
@@ -33,6 +33,8 @@ The camel-splunk-hec sink connector supports 11 options,
which are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.splunkURL* | Splunk Host URL | null | true | HIGH
| *camel.sink.path.token* | Splunk authorization token | null | true | HIGH
+| *camel.sink.endpoint.bodyOnly* | Send only the message body | false | false
| MEDIUM
+| *camel.sink.endpoint.headersOnly* | Send only message headers | false |
false | MEDIUM
| *camel.sink.endpoint.host* | Splunk host. | null | false | MEDIUM
| *camel.sink.endpoint.index* | Splunk index to write to | "camel" | 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 [...]
diff --git
a/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-sink-connector.adoc
index 83ff9ea..c952438 100644
---
a/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-sink-connector.adoc
@@ -24,14 +24,15 @@
connector.class=org.apache.camel.kafkaconnector.twittertimeline.CamelTwittertime
----
-The camel-twitter-timeline sink connector supports 21 options, which are
listed below.
+The camel-twitter-timeline sink connector supports 22 options, which are
listed below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN] | null | true |
HIGH
+| *camel.sink.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN] | null |
true | HIGH
+| *camel.sink.endpoint.list* | The list name when using timelineType=list |
null | false | MEDIUM
| *camel.sink.endpoint.user* | The username when using timelineType=user |
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.httpProxyHost* | The http proxy host which can be used
for the camel-twitter. Can also be configured on the TwitterComponent level
instead. | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-source-connector.adoc
index 9ce8e99..9f9806f 100644
---
a/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-twitter-timeline-kafka-source-connector.adoc
@@ -24,14 +24,15 @@
connector.class=org.apache.camel.kafkaconnector.twittertimeline.CamelTwittertime
----
-The camel-twitter-timeline source connector supports 53 options, which are
listed below.
+The camel-twitter-timeline source connector supports 54 options, which are
listed below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.source.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [UNKNOWN] | null | true |
HIGH
+| *camel.source.path.timelineType* | The timeline type to produce/consume. One
of: [PUBLIC] [HOME] [USER] [MENTIONS] [RETWEETSOFME] [LIST] [UNKNOWN] | null |
true | HIGH
+| *camel.source.endpoint.list* | The list name when using timelineType=list |
null | false | MEDIUM
| *camel.source.endpoint.user* | The username when using timelineType=user |
null | false | MEDIUM
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.source.endpoint.sendEmptyMessageWhenIdle* | If the polling consumer
did not poll any files, you can enable this option to send an empty message (no
body) instead. | false | false | MEDIUM
