This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch 4.4.x in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 8f6d1ebd3352ffb6bee3f217fb91e8ef393ffe8d Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Mar 12 07:13:56 2024 +0100 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Source Signed-off-by: Andrea Cosentino <[email protected]> --- .../main/resources/kamelets/kafka-not-secured-source.kamelet.yaml | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml index 69827c57..0e14bd08 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml @@ -87,6 +87,11 @@ spec: description: When enabled the Kamelet source will deserialize all message headers to String representation. type: boolean default: true + 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.4.0" - "camel:kafka" @@ -107,6 +112,7 @@ spec: pollOnError: "{{pollOnError}}" autoOffsetReset: "{{autoOffsetReset}}" groupId: "{{?consumerGroup}}" + topicIsPattern: "{{topicIsPattern}}" steps: - process: ref: "{{kafkaHeaderDeserializer}}"
