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 d5b571df3e4ccfc41526e258f5df919c61881dee
Author: Andrea Cosentino <[email protected]>
AuthorDate: Tue Mar 12 07:01:00 2024 +0100

    Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio 
not secured
    
    Signed-off-by: Andrea Cosentino <[email protected]>
---
 kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml 
b/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
index cd9e1390..ca62556a 100644
--- a/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
@@ -105,6 +105,11 @@ spec:
         description: How to read data with Avro
         type: string
         default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
+      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"
@@ -127,6 +132,7 @@ spec:
         autoOffsetReset: "{{autoOffsetReset}}"
         groupId: "{{?consumerGroup}}"
         valueDeserializer: "{{valueDeserializer}}"
+        topicIsPattern: "{{topicIsPattern}}"
         additionalProperties.apicurio.registry.url: "{{apicurioRegistryUrl}}"
         additionalProperties.apicurio.registry.avro-datum-provider: 
"{{avroDatumProvider}}"
       steps:

Reply via email to