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:29 UTC
(camel-kamelets) branch 1939 created (now 402f908a)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 1939
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 402f908a Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
This branch includes the following new commits:
new 985b1dec Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Source
new 5014d673 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka SSL Source
new 80493ab7 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Scram Source
new af970fc1 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Source
new 0f935d35 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Apicurio Source
new 23964bf6 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
new 1e522f4f Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
new 527f8852 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
new 8b3a2c63 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
new 9257e65a Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
new 402f908a Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(camel-kamelets) 04/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Source
Posted by ac...@apache.org.
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 af970fc1a2b95db30dae1670e6c2330f464530b7
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:50:48 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-not-secured-source.kamelet.yaml | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index 9f832885..5146b646 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -87,6 +87,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.5.0-SNAPSHOT"
- "camel:kafka"
@@ -107,6 +112,7 @@ spec:
pollOnError: "{{pollOnError}}"
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
(camel-kamelets) 06/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
Posted by ac...@apache.org.
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 23964bf6211b81ca9da2025a7c1dee8cb8e6486b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:55:44 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 6 ++++++
kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml | 6 ++++++
kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 6 ++++++
kamelets/kafka-batch-not-secured-source.kamelet.yaml | 6 ++++++
kamelets/kafka-batch-scram-source.kamelet.yaml | 6 ++++++
kamelets/kafka-batch-source.kamelet.yaml | 8 +++++++-
kamelets/kafka-batch-ssl-source.kamelet.yaml | 6 ++++++
7 files changed, 43 insertions(+), 1 deletion(-)
diff --git a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index c457edbb..02e87701 100644
--- a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -119,6 +119,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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"
@@ -150,6 +155,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml b/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
index 4e3726ab..e94532e0 100644
--- a/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
@@ -160,6 +160,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"
@@ -197,6 +202,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index c0033146..d867d8f3 100644
--- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -139,6 +139,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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"
@@ -176,6 +181,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
additionalProperties.schema.group: avro
additionalProperties.schema.registry.credential: '#bean:defaultAzureCredential'
diff --git a/kamelets/kafka-batch-not-secured-source.kamelet.yaml b/kamelets/kafka-batch-not-secured-source.kamelet.yaml
index 90d3fdf6..f241c4b4 100644
--- a/kamelets/kafka-batch-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-not-secured-source.kamelet.yaml
@@ -101,6 +101,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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"
@@ -128,6 +133,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/kamelets/kafka-batch-scram-source.kamelet.yaml b/kamelets/kafka-batch-scram-source.kamelet.yaml
index 4715fbe1..8042ff5a 100644
--- a/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -132,6 +132,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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:core"
@@ -162,6 +167,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/kamelets/kafka-batch-source.kamelet.yaml b/kamelets/kafka-batch-source.kamelet.yaml
index 9605364e..92285e85 100644
--- a/kamelets/kafka-batch-source.kamelet.yaml
+++ b/kamelets/kafka-batch-source.kamelet.yaml
@@ -132,6 +132,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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:core"
@@ -161,7 +166,8 @@ spec:
pollTimeoutMs: "{{pollTimeout}}"
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
- kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/kamelets/kafka-batch-ssl-source.kamelet.yaml b/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 9e91bc5f..9a081ce8 100644
--- a/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -156,6 +156,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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:core"
@@ -190,6 +195,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
(camel-kamelets) 10/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
Posted by ac...@apache.org.
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:
(camel-kamelets) 07/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
Posted by ac...@apache.org.
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 1e522f4f047477858ab6a01277642e825308efbf
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:57:01 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 6 ++++++
.../kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml | 6 ++++++
.../kafka-batch-azure-schema-registry-source.kamelet.yaml | 6 ++++++
.../kamelets/kafka-batch-not-secured-source.kamelet.yaml | 6 ++++++
.../main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/kafka-batch-source.kamelet.yaml | 8 +++++++-
.../main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml | 6 ++++++
.../kafka-not-secured-apicurio-registry-source.kamelet.yaml | 6 ++++++
.../main/resources/kamelets/kafka-not-secured-source.kamelet.yaml | 6 ++++++
9 files changed, 55 insertions(+), 1 deletion(-)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index c457edbb..02e87701 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -119,6 +119,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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"
@@ -150,6 +155,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
index 4e3726ab..e94532e0 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
@@ -160,6 +160,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"
@@ -197,6 +202,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index c0033146..d867d8f3 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -139,6 +139,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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"
@@ -176,6 +181,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
additionalProperties.schema.group: avro
additionalProperties.schema.registry.credential: '#bean:defaultAzureCredential'
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
index 90d3fdf6..f241c4b4 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
@@ -101,6 +101,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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"
@@ -128,6 +133,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
index 4715fbe1..8042ff5a 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -132,6 +132,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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:core"
@@ -162,6 +167,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
index 9605364e..92285e85 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
@@ -132,6 +132,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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:core"
@@ -161,7 +166,8 @@ spec:
pollTimeoutMs: "{{pollTimeout}}"
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
- kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 9e91bc5f..9a081ce8 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -156,6 +156,11 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when using consumer group management
type: int
+ 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:core"
@@ -190,6 +195,7 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
+ topicIsPattern: "{{topicIsPattern}}"
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
index 657de996..ec870462 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/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}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
index 9f832885..5146b646 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -87,6 +87,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.5.0-SNAPSHOT"
- "camel:kafka"
@@ -107,6 +112,7 @@ spec:
pollOnError: "{{pollOnError}}"
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
(camel-kamelets) 09/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
Posted by ac...@apache.org.
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 8b3a2c637616ffc6f7c3474b9dac67c169cba4ad
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:59:55 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 2faffdde..799d2a8a 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -125,6 +125,11 @@ spec:
description: The Specific Type Avro will have to deal with
type: string
example: "com.example.Order"
+ 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"
@@ -155,6 +160,7 @@ spec:
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
valueDeserializer: "{{valueDeserializer}}"
+ topicIsPattern: "{{topicIsPattern}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
additionalProperties.schema.group: avro
additionalProperties.schema.registry.credential: '#bean:defaultAzureCredential'
(camel-kamelets) 05/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Apicurio Source
Posted by ac...@apache.org.
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}}"
(camel-kamelets) 02/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka SSL Source
Posted by ac...@apache.org.
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 5014d67313f76870fab4f09f50a30a313bf37ea3
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:46:54 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka SSL Source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-ssl-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml | 6 ++++++
2 files changed, 12 insertions(+)
diff --git a/kamelets/kafka-ssl-source.kamelet.yaml b/kamelets/kafka-ssl-source.kamelet.yaml
index 712aac73..f15bbeb8 100644
--- a/kamelets/kafka-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-ssl-source.kamelet.yaml
@@ -142,6 +142,11 @@ spec:
description: Java Authentication and Authorization Service (JAAS) for Simple Authentication and Security Layer (SASL) configuration.
title: JAAS Configuration
type: string
+ 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:core"
@@ -169,6 +174,7 @@ spec:
allowManualCommit: '{{allowManualCommit}}'
autoCommitEnable: '{{autoCommitEnable}}'
saslJaasConfig: '{{?saslJaasConfig}}'
+ topicIsPattern: '{{topicIsPattern}}'
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
index 712aac73..f15bbeb8 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
@@ -142,6 +142,11 @@ spec:
description: Java Authentication and Authorization Service (JAAS) for Simple Authentication and Security Layer (SASL) configuration.
title: JAAS Configuration
type: string
+ 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:core"
@@ -169,6 +174,7 @@ spec:
allowManualCommit: '{{allowManualCommit}}'
autoCommitEnable: '{{autoCommitEnable}}'
saslJaasConfig: '{{?saslJaasConfig}}'
+ topicIsPattern: '{{topicIsPattern}}'
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
(camel-kamelets) 11/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
Posted by ac...@apache.org.
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 402f908a8e460f2b074d4e947b1e6ddad06c3c78
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 07:03:09 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../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 5ed1a3ca..19f5b82e 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:
(camel-kamelets) 03/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Scram Source
Posted by ac...@apache.org.
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 80493ab7c390de297e0766b6538b3beac3a28f92
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 92a30bb0..1448377f 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.5.0-SNAPSHOT"
- "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 92a30bb0..1448377f 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.5.0-SNAPSHOT"
- "camel:core"
@@ -141,6 +146,7 @@ spec:
pollOnError: "{{pollOnError}}"
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
(camel-kamelets) 01/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Source
Posted by ac...@apache.org.
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 985b1decc27842c7db0f032f7638021ec04bf126
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:44:42 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/kafka-source.kamelet.yaml | 6 ++++++
2 files changed, 12 insertions(+)
diff --git a/kamelets/kafka-source.kamelet.yaml b/kamelets/kafka-source.kamelet.yaml
index 198470db..f8b9e823 100644
--- a/kamelets/kafka-source.kamelet.yaml
+++ b/kamelets/kafka-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.5.0-SNAPSHOT"
- "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-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
index 198470db..f8b9e823 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-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.5.0-SNAPSHOT"
- "camel:core"
@@ -141,6 +146,7 @@ spec:
pollOnError: "{{pollOnError}}"
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
+ topicIsPattern: "{{topicIsPattern}}"
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
(camel-kamelets) 08/11: Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
Posted by ac...@apache.org.
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 527f8852cb027941d400610427d00c608d878057
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 12 06:58:16 2024 +0100
Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 2faffdde..799d2a8a 100644
--- a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -125,6 +125,11 @@ spec:
description: The Specific Type Avro will have to deal with
type: string
example: "com.example.Order"
+ 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"
@@ -155,6 +160,7 @@ spec:
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
valueDeserializer: "{{valueDeserializer}}"
+ topicIsPattern: "{{topicIsPattern}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
additionalProperties.schema.group: avro
additionalProperties.schema.registry.credential: '#bean:defaultAzureCredential'