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:39 UTC
(camel-kamelets) 10/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
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 9257e65a9348a004c31b24749398084f904ad0cc
Author: Andrea Cosentino <an...@gmail.com>
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 <an...@gmail.com>
---
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 5ed1a3ca..19f5b82e 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.5.0-SNAPSHOT"
- "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: