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:14:22 UTC
(camel-kamelets) 02/09: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Scram Source
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 bf10b94a97d36f422719495649c2826a3acaa7e7
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:49:20 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Scram Source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-scram-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/kafka-scram-source.kamelet.yaml | 6 ++++++
2 files changed, 12 insertions(+)
diff --git a/kamelets/kafka-scram-source.kamelet.yaml b/kamelets/kafka-scram-source.kamelet.yaml
index 50847e56..03bd4675 100644
--- a/kamelets/kafka-scram-source.kamelet.yaml
+++ b/kamelets/kafka-scram-source.kamelet.yaml
@@ -118,6 +118,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:core"
@@ -141,6 +146,7 @@ spec:
pollOnError: "{{pollOnError}}"
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
index 50847e56..03bd4675 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
@@ -118,6 +118,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:core"
@@ -141,6 +146,7 @@ spec:
pollOnError: "{{pollOnError}}"
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"