This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 247-not-secured
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit e2cddebb2fbfbe0a33055842969f690f0f81cb3f
Author: Andrea Cosentino <anco...@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"
