This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch 1939 in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 5014d67313f76870fab4f09f50a30a313bf37ea3 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Mar 12 06:46:54 2024 +0100 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka SSL Source Signed-off-by: Andrea Cosentino <[email protected]> --- kamelets/kafka-ssl-source.kamelet.yaml | 6 ++++++ .../src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml | 6 ++++++ 2 files changed, 12 insertions(+) diff --git a/kamelets/kafka-ssl-source.kamelet.yaml b/kamelets/kafka-ssl-source.kamelet.yaml index 712aac73..f15bbeb8 100644 --- a/kamelets/kafka-ssl-source.kamelet.yaml +++ b/kamelets/kafka-ssl-source.kamelet.yaml @@ -142,6 +142,11 @@ spec: description: Java Authentication and Authorization Service (JAAS) for Simple Authentication and Security Layer (SASL) configuration. title: JAAS Configuration type: string + topicIsPattern: + title: Topic Is Pattern + description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern. + type: boolean + default: false dependencies: - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.5.0-SNAPSHOT" - "camel:core" @@ -169,6 +174,7 @@ spec: allowManualCommit: '{{allowManualCommit}}' autoCommitEnable: '{{autoCommitEnable}}' saslJaasConfig: '{{?saslJaasConfig}}' + topicIsPattern: '{{topicIsPattern}}' type: '#class:org.apache.camel.component.kafka.KafkaConfiguration' - name: kafkaHeaderDeserializer type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer" 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 712aac73..f15bbeb8 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 @@ -142,6 +142,11 @@ spec: description: Java Authentication and Authorization Service (JAAS) for Simple Authentication and Security Layer (SASL) configuration. title: JAAS Configuration type: string + topicIsPattern: + title: Topic Is Pattern + description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern. + type: boolean + default: false dependencies: - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.5.0-SNAPSHOT" - "camel:core" @@ -169,6 +174,7 @@ spec: allowManualCommit: '{{allowManualCommit}}' autoCommitEnable: '{{autoCommitEnable}}' saslJaasConfig: '{{?saslJaasConfig}}' + topicIsPattern: '{{topicIsPattern}}' type: '#class:org.apache.camel.component.kafka.KafkaConfiguration' - name: kafkaHeaderDeserializer type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
