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:05:33 UTC
(camel-kamelets) branch main updated (4684011e -> 84694011)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from 4684011e Bump org.apache.maven.plugins:maven-gpg-plugin from 3.1.0 to 3.2.0 (#1940)
new 3272bb15 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Source
new 4807c6e2 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka SSL Source
new 85dbaf46 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Scram Source
new f82b358d Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Source
new 3d065486 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Not secured Apicurio Source
new 224f2857 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
new 7e9d3e79 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Batch Source Kamelets
new 08500d96 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
new 705bc9f9 Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Azure Source Kamelet
new b354256a Support topicIsPattern as Kafka Source Kamelets parameter - Kafka Apicurio not secured
new 84694011 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.
Summary of changes:
kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml | 6 ++++++
kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 6 ++++++
.../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 ++++++
kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml | 6 ++++++
kamelets/kafka-not-secured-source.kamelet.yaml | 6 ++++++
kamelets/kafka-scram-source.kamelet.yaml | 6 ++++++
kamelets/kafka-source.kamelet.yaml | 6 ++++++
kamelets/kafka-ssl-source.kamelet.yaml | 6 ++++++
.../kafka-apicurio-registry-not-secured-source.kamelet.yaml | 6 ++++++
.../kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 6 ++++++
.../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 ++++++
.../src/main/resources/kamelets/kafka-scram-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/kafka-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml | 6 ++++++
28 files changed, 170 insertions(+), 2 deletions(-)
(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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit f82b358dadca550098e663c9c5eba451c1838723
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3272bb156a3469e0c9ddf52e4f4e57daa5dada10
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7e9d3e790d7094b3831f89a8b6cc446687a90010
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 4807c6e2eff6be5176c28378f2d8078fca051e2b
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 08500d96d98681b0d1abdec9b69e18ce23f67a50
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'
(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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 85dbaf46cf0c40b38786bd536852e8a956911268
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 705bc9f9fd3f32965a654d0beae3b89205759db3
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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3d0654860acea989af24dd1c117c6797cac4adaa
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit b354256a3e54e9eec6510481f5b878316ff8d5d2
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 224f28577f9f9eb42556069f7060db3aaca66a05
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) 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 8469401192365bbff2c7c897aafbb47f6b9ef63a
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: