You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/03/12 06:03:34 UTC

(camel-kamelets) 05/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Apicurio Source

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 0f935d35ccef45e69e6f66337a87dd35697f7941
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:52:12 2024 +0100

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

diff --git a/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml b/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
index 657de996..ec870462 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
@@ -146,6 +146,11 @@ spec:
         - urn:camel:group:credentials
         - urn:keda:authentication:password
         - urn:keda:required
+      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:kafka"
@@ -168,6 +173,7 @@ spec:
         autoOffsetReset: "{{autoOffsetReset}}"
         groupId: "{{?consumerGroup}}"
         valueDeserializer: "{{valueDeserializer}}"
+        topicIsPattern: "{{topicIsPattern}}"
         additionalProperties.apicurio.registry.url: "{{apicurioRegistryUrl}}"
         additionalProperties.apicurio.registry.avro-datum-provider: "{{avroDatumProvider}}"
         additionalProperties.apicurio.auth.service.url: "{{apicurioAuthServiceUrl}}"