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 545153722c50a1773b76a05bf4c6f09e9293f40c Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Apr 11 06:56:05 2022 +0200 Add back Kafka SSL Source Kamelet --- .../src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml index cc131e42..141a1cc4 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml @@ -90,6 +90,14 @@ spec: default: "latest" x-descriptors: - urn:keda:metadata:offsetResetPolicy + consumerGroup: + title: Consumer Group + description: A string that uniquely identifies the group of consumers to which this source belongs + type: string + example: "my-group-id" + x-descriptors: + - urn:keda:metadata:consumerGroup + - urn:keda:required consumerGroup: title: Consumer Group description: A string that uniquely identifies the group of consumers to which this source belongs @@ -173,7 +181,7 @@ spec: - key: saslMechanism value: '{{saslMechanism}}' - key: groupId - value: '{{groupId}}' + value: '{{?consumerGroup}}' - key: autoOffsetReset value: '{{autoOffsetReset}}' - key: pollOnError
