(camel-kamelets) 03/09: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Source

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 1939-4.4.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 51d69478b9f9022515aed0d3248d3c93d07f9ca0
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:50:48 2024 +0100

    Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Source
    
    Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
 kamelets/kafka-not-secured-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index 69827c57..0e14bd08 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/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}}"