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 <anco...@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"
