You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/05/11 11:24:16 UTC
[camel-kamelets] branch main updated (b0f8931 -> dd55612)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.
from b0f8931 Regen for commit e896dfa5ace635f761ea6bf4ac5769534a917327
new db5ce39 Kafka Not Secured Source Kamelet: Added options
new 112d742 Regen catalog
new aef7f33 Kafka Not Secured Source Kamelet: Added options
new 75b341f Kafka Not Secured Source Kamelet: Added options
new dd55612 Regen catalog
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../ROOT/pages/kafka-not-secured-source.adoc | 4 ++++
kafka-not-secured-source.kamelet.yaml | 28 ++++++++++++++++++++++
.../kamelets/kafka-not-secured-source.kamelet.yaml | 28 ++++++++++++++++++++++
3 files changed, 60 insertions(+)
[camel-kamelets] 03/05: Kafka Not Secured Source Kamelet: Added
options
Posted by ac...@apache.org.
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-kamelets.git
commit aef7f331bebc142131bbc7b0cc37db35937cd59c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 13:11:11 2021 +0200
Kafka Not Secured Source Kamelet: Added options
---
docs/modules/ROOT/pages/kafka-not-secured-source.adoc | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/docs/modules/ROOT/pages/kafka-not-secured-source.adoc b/docs/modules/ROOT/pages/kafka-not-secured-source.adoc
index 6620a9b..5178af6 100644
--- a/docs/modules/ROOT/pages/kafka-not-secured-source.adoc
+++ b/docs/modules/ROOT/pages/kafka-not-secured-source.adoc
@@ -13,6 +13,10 @@ The following table summarizes the configuration options available for the `kafk
| Property| Name| Description| Type| Default| Example
| *brokers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| |
+| allowManualCommit| Allow Manual Commit| Whether to allow doing manual commits| boolean| `false`|
+| autoCommitEnable| Auto Commit Enable| If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer| boolean| `true`|
+| autoOffsetReset| Auto Offset Reset| What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none| string| `"latest"`|
+| pollOnError| Poll On Error Behavior| What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP| string| `"ERROR_HANDLER"`|
|===
NOTE: Fields marked with ({empty}*) are mandatory.
[camel-kamelets] 02/05: Regen catalog
Posted by ac...@apache.org.
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-kamelets.git
commit 112d7420f7888d370d35444af9897c7d41528092
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 13:10:46 2021 +0200
Regen catalog
---
.../kamelets/kafka-not-secured-source.kamelet.yaml | 28 ++++++++++++++++++++++
1 file changed, 28 insertions(+)
diff --git a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
index 704dddb..55a93e2 100644
--- a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -26,6 +26,30 @@ spec:
title: Brokers
description: Comma separated list of Kafka Broker URLs
type: string
+ autoCommitEnable:
+ title: Auto Commit Enable
+ description: If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer
+ type: boolean
+ default: true
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ allowManualCommit:
+ title: Allow Manual Commit
+ description: Whether to allow doing manual commits
+ type: boolean
+ default: false
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ pollOnError:
+ title: Poll On Error Behavior
+ description: What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP
+ type: string
+ default: "ERROR_HANDLER"
+ autoOffsetReset:
+ title: Auto Offset Reset
+ description: What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none
+ type: string
+ default: "latest"
dependencies:
- "camel:kafka"
- "camel:kamelet"
@@ -34,5 +58,9 @@ spec:
uri: "kafka:{{topic}}"
parameters:
brokers: "{{brokers}}"
+ autoCommitEnable: "{{autoCommitEnable}}"
+ allowManualCommit: "{{allowManualCommit}}"
+ pollOnError: "{{pollOnError}}"
+ autoOffsetReset: "{{pollOnError}}"
steps:
- to: "kamelet:sink"
[camel-kamelets] 04/05: Kafka Not Secured Source Kamelet: Added
options
Posted by ac...@apache.org.
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-kamelets.git
commit 75b341f7e2e188596606fe7ce78cb42fa39e3781
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 13:21:26 2021 +0200
Kafka Not Secured Source Kamelet: Added options
---
kafka-not-secured-source.kamelet.yaml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/kafka-not-secured-source.kamelet.yaml b/kafka-not-secured-source.kamelet.yaml
index 55a93e2..bb7e1a6 100644
--- a/kafka-not-secured-source.kamelet.yaml
+++ b/kafka-not-secured-source.kamelet.yaml
@@ -61,6 +61,6 @@ spec:
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"
- autoOffsetReset: "{{pollOnError}}"
+ autoOffsetReset: "{{autoOffsetReset}}"
steps:
- to: "kamelet:sink"
[camel-kamelets] 01/05: Kafka Not Secured Source Kamelet: Added
options
Posted by ac...@apache.org.
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-kamelets.git
commit db5ce3962ed166c3d9ab05ad4ed5d9cd99e623db
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 13:07:17 2021 +0200
Kafka Not Secured Source Kamelet: Added options
---
kafka-not-secured-source.kamelet.yaml | 28 ++++++++++++++++++++++++++++
1 file changed, 28 insertions(+)
diff --git a/kafka-not-secured-source.kamelet.yaml b/kafka-not-secured-source.kamelet.yaml
index 704dddb..55a93e2 100644
--- a/kafka-not-secured-source.kamelet.yaml
+++ b/kafka-not-secured-source.kamelet.yaml
@@ -26,6 +26,30 @@ spec:
title: Brokers
description: Comma separated list of Kafka Broker URLs
type: string
+ autoCommitEnable:
+ title: Auto Commit Enable
+ description: If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer
+ type: boolean
+ default: true
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ allowManualCommit:
+ title: Allow Manual Commit
+ description: Whether to allow doing manual commits
+ type: boolean
+ default: false
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ pollOnError:
+ title: Poll On Error Behavior
+ description: What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP
+ type: string
+ default: "ERROR_HANDLER"
+ autoOffsetReset:
+ title: Auto Offset Reset
+ description: What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none
+ type: string
+ default: "latest"
dependencies:
- "camel:kafka"
- "camel:kamelet"
@@ -34,5 +58,9 @@ spec:
uri: "kafka:{{topic}}"
parameters:
brokers: "{{brokers}}"
+ autoCommitEnable: "{{autoCommitEnable}}"
+ allowManualCommit: "{{allowManualCommit}}"
+ pollOnError: "{{pollOnError}}"
+ autoOffsetReset: "{{pollOnError}}"
steps:
- to: "kamelet:sink"
[camel-kamelets] 05/05: Regen catalog
Posted by ac...@apache.org.
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-kamelets.git
commit dd556129fadd8945fa0938139aabc37f0702b94b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 13:21:46 2021 +0200
Regen catalog
---
.../src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
index 55a93e2..bb7e1a6 100644
--- a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -61,6 +61,6 @@ spec:
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"
- autoOffsetReset: "{{pollOnError}}"
+ autoOffsetReset: "{{autoOffsetReset}}"
steps:
- to: "kamelet:sink"