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 12:42:25 UTC
[camel-kamelets] branch 247-kafka-secured created (now 3dd959c)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 247-kafka-secured
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.
at 3dd959c Kafka Source Kamelet: Added more options
This branch includes the following new commits:
new 1c4bd68 Kafka Source Kamelet: Added options
new bdb878c Regen catalog
new 3dd959c Kafka Source Kamelet: Added more options
The 3 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.
[camel-kamelets] 01/03: Kafka 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 247-kafka-secured
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 1c4bd6889e149d03e0c6d9917d6e1f1a41a51283
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 14:39:31 2021 +0200
Kafka Source Kamelet: Added options
---
kafka-source.kamelet.yaml | 28 ++++++++++++++++++++++++++++
1 file changed, 28 insertions(+)
diff --git a/kafka-source.kamelet.yaml b/kafka-source.kamelet.yaml
index f5cd98a..a2d96b5 100644
--- a/kafka-source.kamelet.yaml
+++ b/kafka-source.kamelet.yaml
@@ -49,6 +49,30 @@ spec:
format: password
x-descriptors:
- urn:alm:descriptor:com.tectonic.ui:password
+ 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"
@@ -60,5 +84,9 @@ spec:
securityProtocol: "{{securityProtocol}}"
saslMechanism: "{{saslMechanism}}"
saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{username}}' password='{{password}}';"
+ autoCommitEnable: "{{autoCommitEnable}}"
+ allowManualCommit: "{{allowManualCommit}}"
+ pollOnError: "{{pollOnError}}"
+ autoOffsetReset: "{{autoOffsetReset}}"
steps:
- to: "kamelet:sink"
[camel-kamelets] 03/03: Kafka Source Kamelet: Added more options
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 247-kafka-secured
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3dd959ca8df2e09eed239653e514ffd3b73d5312
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 14:41:14 2021 +0200
Kafka Source Kamelet: Added more options
---
docs/modules/ROOT/pages/kafka-source.adoc | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/docs/modules/ROOT/pages/kafka-source.adoc b/docs/modules/ROOT/pages/kafka-source.adoc
index a095dd3..2544375 100644
--- a/docs/modules/ROOT/pages/kafka-source.adoc
+++ b/docs/modules/ROOT/pages/kafka-source.adoc
@@ -15,6 +15,10 @@ The following table summarizes the configuration options available for the `kafk
| *password {empty}* *| Password| Password to authenticate to kafka| string| |
| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| |
| *username {empty}* *| Username| Username to authenticate to Kafka| 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"`|
| saslMechanism| SASL Mechanism| The Simple Authentication and Security Layer (SASL) Mechanism used.| string| `"PLAIN"`|
| securityProtocol| Security Protocol| Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported| string| `"SASL_SSL"`|
|===
[camel-kamelets] 02/03: 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 247-kafka-secured
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit bdb878cfe59acbbe08963a1d723a646e8af5a4c7
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 11 14:40:43 2021 +0200
Regen catalog
---
.../resources/kamelets/kafka-source.kamelet.yaml | 28 ++++++++++++++++++++++
1 file changed, 28 insertions(+)
diff --git a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
index f5cd98a..a2d96b5 100644
--- a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
+++ b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
@@ -49,6 +49,30 @@ spec:
format: password
x-descriptors:
- urn:alm:descriptor:com.tectonic.ui:password
+ 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"
@@ -60,5 +84,9 @@ spec:
securityProtocol: "{{securityProtocol}}"
saslMechanism: "{{saslMechanism}}"
saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{username}}' password='{{password}}';"
+ autoCommitEnable: "{{autoCommitEnable}}"
+ allowManualCommit: "{{allowManualCommit}}"
+ pollOnError: "{{pollOnError}}"
+ autoOffsetReset: "{{autoOffsetReset}}"
steps:
- to: "kamelet:sink"