From 8469401192365bbff2c7c897aafbb47f6b9ef63a Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Tue, 12 Mar 2024 07:03:09 +0100 Subject: [PATCH] Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured Signed-off-by: Andrea Cosentino --- .../kafka-apicurio-registry-not-secured-source.kamelet.yaml | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml index 5ed1a3cae..19f5b82ef 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/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: