This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new 28ad3dd11 chore: remove keda descriptors
28ad3dd11 is described below
commit 28ad3dd11f92f0209733e2f3f94f54504e1ffca9
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Thu Oct 2 09:27:11 2025 +0200
chore: remove keda descriptors
* They were used in an experimental Camel K feature
* Removed as they requires the operator to access to the secrets
* Also, the auth model suggest the usage of a separate credentials from the
application's one
---
kamelets/aws-s3-event-based-source.kamelet.yaml | 13 +------------
kamelets/aws-sqs-source.kamelet.yaml | 13 +------------
.../jms-pooled-apache-artemis-sink.kamelet.yaml | 8 ++------
.../jms-pooled-apache-artemis-source.kamelet.yaml | 8 ++------
...apicurio-registry-not-secured-sink.kamelet.yaml | 3 ---
...icurio-registry-not-secured-source.kamelet.yaml | 15 ---------------
.../kafka-azure-schema-registry-sink.kamelet.yaml | 5 +----
...kafka-azure-schema-registry-source.kamelet.yaml | 17 -----------------
...icurio-registry-not-secured-source.kamelet.yaml | 15 ---------------
...fka-batch-apicurio-registry-source.kamelet.yaml | 19 -------------------
...batch-azure-schema-registry-source.kamelet.yaml | 17 -----------------
.../kafka-batch-not-secured-source.kamelet.yaml | 12 ------------
kamelets/kafka-batch-scram-source.kamelet.yaml | 18 ------------------
kamelets/kafka-batch-source.kamelet.yaml | 22 ++--------------------
kamelets/kafka-batch-ssl-source.kamelet.yaml | 16 ----------------
...ured-apicurio-registry-json-source.kamelet.yaml | 19 -------------------
...not-secured-apicurio-registry-sink.kamelet.yaml | 7 -------
...t-secured-apicurio-registry-source.kamelet.yaml | 19 -------------------
kamelets/kafka-not-secured-source.kamelet.yaml | 12 ------------
kamelets/kafka-scram-source.kamelet.yaml | 18 ------------------
kamelets/kafka-source.kamelet.yaml | 18 ------------------
kamelets/kafka-ssl-source.kamelet.yaml | 17 -----------------
.../aws-s3-event-based-source.kamelet.yaml | 13 +------------
.../resources/kamelets/aws-sqs-source.kamelet.yaml | 13 +------------
.../jms-pooled-apache-artemis-sink.kamelet.yaml | 8 ++------
.../jms-pooled-apache-artemis-source.kamelet.yaml | 8 ++------
...apicurio-registry-not-secured-sink.kamelet.yaml | 3 ---
...icurio-registry-not-secured-source.kamelet.yaml | 15 ---------------
.../kafka-azure-schema-registry-sink.kamelet.yaml | 5 +----
...kafka-azure-schema-registry-source.kamelet.yaml | 17 -----------------
...icurio-registry-not-secured-source.kamelet.yaml | 15 ---------------
...fka-batch-apicurio-registry-source.kamelet.yaml | 19 -------------------
...batch-azure-schema-registry-source.kamelet.yaml | 17 -----------------
.../kafka-batch-not-secured-source.kamelet.yaml | 12 ------------
.../kamelets/kafka-batch-scram-source.kamelet.yaml | 18 ------------------
.../kamelets/kafka-batch-source.kamelet.yaml | 22 ++--------------------
.../kamelets/kafka-batch-ssl-source.kamelet.yaml | 16 ----------------
...ured-apicurio-registry-json-source.kamelet.yaml | 19 -------------------
...not-secured-apicurio-registry-sink.kamelet.yaml | 7 -------
...t-secured-apicurio-registry-source.kamelet.yaml | 19 -------------------
.../kamelets/kafka-not-secured-source.kamelet.yaml | 12 ------------
.../kamelets/kafka-scram-source.kamelet.yaml | 18 ------------------
.../resources/kamelets/kafka-source.kamelet.yaml | 18 ------------------
.../kamelets/kafka-ssl-source.kamelet.yaml | 17 -----------------
script/validator/validator.go | 6 ------
45 files changed, 18 insertions(+), 610 deletions(-)
diff --git a/kamelets/aws-s3-event-based-source.kamelet.yaml
b/kamelets/aws-s3-event-based-source.kamelet.yaml
index 83b4e053a..8c2198587 100644
--- a/kamelets/aws-s3-event-based-source.kamelet.yaml
+++ b/kamelets/aws-s3-event-based-source.kamelet.yaml
@@ -27,7 +27,6 @@ metadata:
camel.apache.org/provider: Apache Software Foundation
camel.apache.org/kamelet.group: AWS S3 Event-Based
camel.apache.org/kamelet.namespace: "AWS"
- camel.apache.org/keda.type: aws-s3-event-based-queue
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -57,8 +56,6 @@ spec:
format: password
x-descriptors:
- 'urn:camel:group:credentials'
- - 'urn:keda:authentication:awsAccessKeyID'
- - 'urn:keda:required'
secretKey:
title: Secret Key
description: The secret key obtained from AWS.
@@ -66,15 +63,10 @@ spec:
format: password
x-descriptors:
- 'urn:camel:group:credentials'
- - 'urn:keda:authentication:awsSecretAccessKey'
- - 'urn:keda:required'
region:
title: AWS Region
description: The AWS region to access.
type: string
- x-descriptors:
- - 'urn:keda:metadata:awsRegion'
- - 'urn:keda:required'
enum:
- ap-south-1
- eu-south-1
@@ -129,11 +121,8 @@ spec:
default: https
queueURL:
title: Queue URL
- description: The full SQS Queue URL (required if using KEDA)
+ description: The full SQS Queue URL
type: string
- x-descriptors:
- - 'urn:keda:metadata:queueURL'
- - 'urn:keda:required'
uriEndpointOverride:
title: Overwrite Endpoint URI
description: >-
diff --git a/kamelets/aws-sqs-source.kamelet.yaml
b/kamelets/aws-sqs-source.kamelet.yaml
index a41b96278..e9e065bc0 100644
--- a/kamelets/aws-sqs-source.kamelet.yaml
+++ b/kamelets/aws-sqs-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/kamelet.icon:
"data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcKICAgeG1sbnM6ZGM9Imh0dHA6Ly9wdXJsLm9yZy9kYy9lbGVtZW50cy8xLjEvIgogICB4bWxuczpjYz0iaHR0cDovL2NyZWF0aXZlY29tbW9ucy5vcmcvbnMjIgogICB4bWxuczpyZGY9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkvMDIvMjItcmRmLXN5bnRheC1ucyMiCiAgIHhtbG5zOnN2Zz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciCiAgIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM6c29kaXBvZGk9Imh0dHA6Ly9zb2RpcG
[...]
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "AWS SQS"
- camel.apache.org/keda.type: "aws-sqs-queue"
camel.apache.org/kamelet.namespace: "AWS"
labels:
camel.apache.org/kamelet.type: "source"
@@ -54,8 +53,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:awsAccessKeyID
- - urn:keda:required
secretKey:
title: Secret Key
description: The secret key obtained from AWS.
@@ -63,15 +60,10 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:awsSecretAccessKey
- - urn:keda:required
region:
title: AWS Region
description: The AWS region to access.
type: string
- x-descriptors:
- - urn:keda:metadata:awsRegion
- - urn:keda:required
enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1",
"ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2",
"af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1",
"ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1",
"sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1",
"ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2",
"cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
autoCreateQueue:
title: Autocreate Queue
@@ -91,11 +83,8 @@ spec:
default: https
queueURL:
title: Queue URL
- description: The full SQS Queue URL (required if using KEDA).
+ description: The full SQS Queue URL.
type: string
- x-descriptors:
- - urn:keda:metadata:queueURL
- - urn:keda:required
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the SQS client loads credentials through a
default credentials provider. If false, it uses the basic authentication method
(access key and secret key).
diff --git a/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
b/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
index 3f7a2304a..9cb53dd78 100644
--- a/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
+++ b/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
@@ -58,21 +58,17 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
password:
title: "Broker Password"
description: "The JMS Broker Password."
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
maxSessionsPerConnection:
title: "Max Sessions Per Connection"
description: "The maximum number of pooled sessions per connection in
the pool."
type: integer
- default: 500
+ default: 500
maxIdleSessionsPerConnection:
title: "Max Idle Sessions Per Connection"
description: "The number of idle sessions allowed per connection
before they are closed."
@@ -82,7 +78,7 @@ spec:
title: "Connection Idle Timeout"
description: "The maximum time a pooled Connection can sit unused
before it is eligible for removal (in milliseconds)."
type: integer
- default: 30000
+ default: 30000
dependencies:
- "camel:jms"
- "camel:kamelet"
diff --git a/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
b/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
index 60c892f42..223076d78 100644
--- a/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
+++ b/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
@@ -57,16 +57,12 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
password:
title: "Broker Password"
description: "The JMS Broker Password."
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
maxSessionsPerConnection:
title: "Max Session Per Connection"
description: "The maximum number of pooled sessions per connection in
the pool."
@@ -81,7 +77,7 @@ spec:
title: "Connection Idle Timeout"
description: "The maximum time a pooled Connection can sit unused
before it is eligible for removal (in milliseconds)."
type: integer
- default: 30000
+ default: 30000
dependencies:
- "camel:jms"
- "camel:kamelet"
@@ -101,7 +97,7 @@ spec:
connectionFactory: '#bean:{{connectionFactoryBean}}'
maxSessionsPerConnection: "{{maxSessionsPerConnection}}"
maxIdleSessionsPerConnection: "{{maxIdleSessionsPerConnection}}"
- connectionIdleTimeout: "{{connectionIdleTimeout}}"
+ connectionIdleTimeout: "{{connectionIdleTimeout}}"
from:
uri: "jms:{{destinationType}}:{{destinationName}}"
parameters:
diff --git a/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
b/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
index ccd3bb742..d468110ac 100644
--- a/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
+++ b/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
@@ -54,9 +54,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL.
type: string
- x-descriptors:
- - urn:keda:metadata:apicurioRegistryUrl
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to write data with Avro.
diff --git a/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
b/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
index fecc09c19..3d67cb0e4 100644
--- a/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -42,16 +41,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -72,16 +65,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -96,9 +84,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - 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.
diff --git a/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
b/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
index 5fc87bd6f..99b9371a4 100644
--- a/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
@@ -53,7 +53,7 @@ spec:
default: SASL_SSL
saslMechanism:
title: SASL Mechanism
- description: The Simple Authentication and Security Layer (SASL)
Mechanism used.
+ description: The Simple Authentication and Security Layer (SASL)
Mechanism used.
type: string
default: PLAIN
password:
@@ -72,9 +72,6 @@ spec:
title: Azure Schema Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
specificAvroValueType:
title: Specific Avro Value Type
description: The Specific Type Avro will have to deal with
diff --git a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 9b177cec2..ac31b29ee 100644
--- a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -43,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -70,8 +63,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -92,16 +83,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -116,9 +102,6 @@ spec:
title: Azure Schema Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
specificAvroValueType:
title: Specific Avro Value Type
description: The Specific Type Avro will have to deal with
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 80e15e3ed..ca6f0824e 100644
--- a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -42,16 +41,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names.
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs.
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer.
@@ -72,16 +65,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of `latest`, `earliest`, `none`.
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs.
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -96,9 +84,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL.
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to read data with Avro.
diff --git a/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
b/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
index 39751c136..86363b654 100644
--- a/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -48,16 +47,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -78,16 +71,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -102,9 +90,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to read data with Avro
@@ -148,8 +133,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -161,8 +144,6 @@ spec:
format: password
x-descriptors:
- 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.
diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index 919080609..d86621b3e 100644
--- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -43,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -70,8 +63,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -92,16 +83,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -116,9 +102,6 @@ spec:
title: Azure Schema Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
specificAvroValueType:
title: Specific Avro Value Type
description: The Specific Type Avro will have to deal with
diff --git a/kamelets/kafka-batch-not-secured-source.kamelet.yaml
b/kamelets/kafka-batch-not-secured-source.kamelet.yaml
index 3bfa2f609..4c1d8cb0e 100644
--- a/kamelets/kafka-batch-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-not-secured-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -41,16 +40,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -71,16 +64,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
diff --git a/kamelets/kafka-batch-scram-source.kamelet.yaml
b/kamelets/kafka-batch-scram-source.kamelet.yaml
index 732892aba..ad5f37d81 100644
--- a/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "scram-sha-512"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
diff --git a/kamelets/kafka-batch-source.kamelet.yaml
b/kamelets/kafka-batch-source.kamelet.yaml
index e4aa244f7..5422a08fc 100644
--- a/kamelets/kafka-batch-source.kamelet.yaml
+++ b/kamelets/kafka-batch-source.kamelet.yaml
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "plaintext"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -169,8 +151,8 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batchingIntervalMs: "{{?batchingIntervalMs}}"
batching: true
- kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
- topicIsPattern: "{{topicIsPattern}}"
+ 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 39371af4d..b5176aa7d 100644
--- a/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -42,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -82,16 +76,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -104,16 +93,11 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
sslKeystorePassword:
description: The store password for the key store file.This is
optional for client and only needed if ssl.keystore.location is configured.
title: SSL Keystore Password
type: string
format: password
- x-descriptors:
- - urn:camel:group:credentials
- - urn:keda:authentication:password
sslEndpointAlgorithm:
description: The endpoint identification algorithm to validate server
hostname using server certificate. Use none or false to disable server hostname
verification.
title: SSL Endpoint Algorithm
diff --git
a/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
b/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
index ba300d8fb..69f8cfdd7 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -48,16 +47,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -78,16 +71,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -102,9 +90,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
apicurioAuthServiceUrl:
title: Apicurio Registry Auth Service URL
description: The URL for Keycloak instance securing the Apicurio
Registry
@@ -125,8 +110,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -138,8 +121,6 @@ spec:
format: password
x-descriptors:
- 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.
diff --git a/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
b/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
index 1fdf0a1a9..1a14ae3c8 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
@@ -60,9 +60,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:apicurioRegistryUrl
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to write data with Avro
@@ -88,8 +85,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -101,8 +96,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
dependencies:
- "camel:core"
- "camel:kamelet"
diff --git a/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
b/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
index 79e9f4e8e..549eb6549 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -48,16 +47,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -78,16 +71,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -102,9 +90,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to read data with Avro
@@ -130,8 +115,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -143,8 +126,6 @@ spec:
format: password
x-descriptors:
- 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.
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml
b/kamelets/kafka-not-secured-source.kamelet.yaml
index 7f008a5a6..dea5bca40 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -41,16 +40,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -71,16 +64,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
diff --git a/kamelets/kafka-scram-source.kamelet.yaml
b/kamelets/kafka-scram-source.kamelet.yaml
index 02951ba04..2d99711f6 100644
--- a/kamelets/kafka-scram-source.kamelet.yaml
+++ b/kamelets/kafka-scram-source.kamelet.yaml
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "scram-sha-512"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
diff --git a/kamelets/kafka-source.kamelet.yaml
b/kamelets/kafka-source.kamelet.yaml
index ed4f260b0..2ee88257c 100644
--- a/kamelets/kafka-source.kamelet.yaml
+++ b/kamelets/kafka-source.kamelet.yaml
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "plaintext"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
diff --git a/kamelets/kafka-ssl-source.kamelet.yaml
b/kamelets/kafka-ssl-source.kamelet.yaml
index ee4b5de02..6020b3837 100644
--- a/kamelets/kafka-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-ssl-source.kamelet.yaml
@@ -43,16 +43,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names.
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs.
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
`SASL_PLAINTEXT`, `PLAINTEXT`, `SASL_SSL` and `SSL` are supported.
@@ -83,16 +77,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none.
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs.
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -103,10 +92,6 @@ spec:
title: SSL Key Password
type: string
format: password
- x-descriptors:
- - urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
sslKeystorePassword:
description: The store password for the key store file.This is
optional for client and only needed if ssl.keystore.location is configured.
title: SSL Keystore Password
@@ -114,7 +99,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
sslEndpointAlgorithm:
description: The endpoint identification algorithm to validate server
hostname using server certificate. Use none or false to disable server hostname
verification.
title: SSL Endpoint Algorithm
@@ -140,7 +124,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
sslEnabledProtocols:
description: The list of protocols enabled for SSL connections.
TLSv1.2, TLSv1.1 and TLSv1 are enabled by default.
title: SSL Enabled Protocols
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-event-based-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-event-based-source.kamelet.yaml
index 83b4e053a..8c2198587 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-event-based-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-event-based-source.kamelet.yaml
@@ -27,7 +27,6 @@ metadata:
camel.apache.org/provider: Apache Software Foundation
camel.apache.org/kamelet.group: AWS S3 Event-Based
camel.apache.org/kamelet.namespace: "AWS"
- camel.apache.org/keda.type: aws-s3-event-based-queue
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -57,8 +56,6 @@ spec:
format: password
x-descriptors:
- 'urn:camel:group:credentials'
- - 'urn:keda:authentication:awsAccessKeyID'
- - 'urn:keda:required'
secretKey:
title: Secret Key
description: The secret key obtained from AWS.
@@ -66,15 +63,10 @@ spec:
format: password
x-descriptors:
- 'urn:camel:group:credentials'
- - 'urn:keda:authentication:awsSecretAccessKey'
- - 'urn:keda:required'
region:
title: AWS Region
description: The AWS region to access.
type: string
- x-descriptors:
- - 'urn:keda:metadata:awsRegion'
- - 'urn:keda:required'
enum:
- ap-south-1
- eu-south-1
@@ -129,11 +121,8 @@ spec:
default: https
queueURL:
title: Queue URL
- description: The full SQS Queue URL (required if using KEDA)
+ description: The full SQS Queue URL
type: string
- x-descriptors:
- - 'urn:keda:metadata:queueURL'
- - 'urn:keda:required'
uriEndpointOverride:
title: Overwrite Endpoint URI
description: >-
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
index a41b96278..e9e065bc0 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/kamelet.icon:
"data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcKICAgeG1sbnM6ZGM9Imh0dHA6Ly9wdXJsLm9yZy9kYy9lbGVtZW50cy8xLjEvIgogICB4bWxuczpjYz0iaHR0cDovL2NyZWF0aXZlY29tbW9ucy5vcmcvbnMjIgogICB4bWxuczpyZGY9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkvMDIvMjItcmRmLXN5bnRheC1ucyMiCiAgIHhtbG5zOnN2Zz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciCiAgIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM6c29kaXBvZGk9Imh0dHA6Ly9zb2RpcG
[...]
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "AWS SQS"
- camel.apache.org/keda.type: "aws-sqs-queue"
camel.apache.org/kamelet.namespace: "AWS"
labels:
camel.apache.org/kamelet.type: "source"
@@ -54,8 +53,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:awsAccessKeyID
- - urn:keda:required
secretKey:
title: Secret Key
description: The secret key obtained from AWS.
@@ -63,15 +60,10 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:awsSecretAccessKey
- - urn:keda:required
region:
title: AWS Region
description: The AWS region to access.
type: string
- x-descriptors:
- - urn:keda:metadata:awsRegion
- - urn:keda:required
enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1",
"ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2",
"af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1",
"ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1",
"sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1",
"ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2",
"cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
autoCreateQueue:
title: Autocreate Queue
@@ -91,11 +83,8 @@ spec:
default: https
queueURL:
title: Queue URL
- description: The full SQS Queue URL (required if using KEDA).
+ description: The full SQS Queue URL.
type: string
- x-descriptors:
- - urn:keda:metadata:queueURL
- - urn:keda:required
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the SQS client loads credentials through a
default credentials provider. If false, it uses the basic authentication method
(access key and secret key).
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
index 3f7a2304a..9cb53dd78 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
@@ -58,21 +58,17 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
password:
title: "Broker Password"
description: "The JMS Broker Password."
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
maxSessionsPerConnection:
title: "Max Sessions Per Connection"
description: "The maximum number of pooled sessions per connection in
the pool."
type: integer
- default: 500
+ default: 500
maxIdleSessionsPerConnection:
title: "Max Idle Sessions Per Connection"
description: "The number of idle sessions allowed per connection
before they are closed."
@@ -82,7 +78,7 @@ spec:
title: "Connection Idle Timeout"
description: "The maximum time a pooled Connection can sit unused
before it is eligible for removal (in milliseconds)."
type: integer
- default: 30000
+ default: 30000
dependencies:
- "camel:jms"
- "camel:kamelet"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
index 60c892f42..223076d78 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
@@ -57,16 +57,12 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
password:
title: "Broker Password"
description: "The JMS Broker Password."
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
maxSessionsPerConnection:
title: "Max Session Per Connection"
description: "The maximum number of pooled sessions per connection in
the pool."
@@ -81,7 +77,7 @@ spec:
title: "Connection Idle Timeout"
description: "The maximum time a pooled Connection can sit unused
before it is eligible for removal (in milliseconds)."
type: integer
- default: 30000
+ default: 30000
dependencies:
- "camel:jms"
- "camel:kamelet"
@@ -101,7 +97,7 @@ spec:
connectionFactory: '#bean:{{connectionFactoryBean}}'
maxSessionsPerConnection: "{{maxSessionsPerConnection}}"
maxIdleSessionsPerConnection: "{{maxIdleSessionsPerConnection}}"
- connectionIdleTimeout: "{{connectionIdleTimeout}}"
+ connectionIdleTimeout: "{{connectionIdleTimeout}}"
from:
uri: "jms:{{destinationType}}:{{destinationName}}"
parameters:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
index ccd3bb742..d468110ac 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
@@ -54,9 +54,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL.
type: string
- x-descriptors:
- - urn:keda:metadata:apicurioRegistryUrl
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to write data with Avro.
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 fecc09c19..3d67cb0e4 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -42,16 +41,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -72,16 +65,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -96,9 +84,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - 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.
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
index 5fc87bd6f..99b9371a4 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
@@ -53,7 +53,7 @@ spec:
default: SASL_SSL
saslMechanism:
title: SASL Mechanism
- description: The Simple Authentication and Security Layer (SASL)
Mechanism used.
+ description: The Simple Authentication and Security Layer (SASL)
Mechanism used.
type: string
default: PLAIN
password:
@@ -72,9 +72,6 @@ spec:
title: Azure Schema Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
specificAvroValueType:
title: Specific Avro Value Type
description: The Specific Type Avro will have to deal with
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 9b177cec2..ac31b29ee 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -43,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -70,8 +63,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -92,16 +83,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -116,9 +102,6 @@ spec:
title: Azure Schema Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
specificAvroValueType:
title: Specific Avro Value Type
description: The Specific Type Avro will have to deal with
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 80e15e3ed..ca6f0824e 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -42,16 +41,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names.
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs.
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer.
@@ -72,16 +65,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of `latest`, `earliest`, `none`.
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs.
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -96,9 +84,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL.
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to read data with Avro.
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 39751c136..86363b654 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -48,16 +47,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -78,16 +71,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -102,9 +90,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to read data with Avro
@@ -148,8 +133,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -161,8 +144,6 @@ spec:
format: password
x-descriptors:
- 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.
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 919080609..d86621b3e 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -43,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -70,8 +63,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -92,16 +83,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -116,9 +102,6 @@ spec:
title: Azure Schema Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
specificAvroValueType:
title: Specific Avro Value Type
description: The Specific Type Avro will have to deal with
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 3bfa2f609..4c1d8cb0e 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -41,16 +40,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -71,16 +64,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
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 732892aba..ad5f37d81 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
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "scram-sha-512"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
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 e4aa244f7..5422a08fc 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
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "plaintext"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -169,8 +151,8 @@ spec:
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batchingIntervalMs: "{{?batchingIntervalMs}}"
batching: true
- kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
- topicIsPattern: "{{topicIsPattern}}"
+ 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 39371af4d..b5176aa7d 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
@@ -42,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -82,16 +76,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -104,16 +93,11 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
sslKeystorePassword:
description: The store password for the key store file.This is
optional for client and only needed if ssl.keystore.location is configured.
title: SSL Keystore Password
type: string
format: password
- x-descriptors:
- - urn:camel:group:credentials
- - urn:keda:authentication:password
sslEndpointAlgorithm:
description: The endpoint identification algorithm to validate server
hostname using server certificate. Use none or false to disable server hostname
verification.
title: SSL Endpoint Algorithm
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
index ba300d8fb..69f8cfdd7 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -48,16 +47,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -78,16 +71,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -102,9 +90,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
apicurioAuthServiceUrl:
title: Apicurio Registry Auth Service URL
description: The URL for Keycloak instance securing the Apicurio
Registry
@@ -125,8 +110,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -138,8 +121,6 @@ spec:
format: password
x-descriptors:
- 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.
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
index 1fdf0a1a9..1a14ae3c8 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
@@ -60,9 +60,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:apicurioRegistryUrl
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to write data with Avro
@@ -88,8 +85,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -101,8 +96,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
dependencies:
- "camel:core"
- "camel:kamelet"
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 79e9f4e8e..549eb6549 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -48,16 +47,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -78,16 +71,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -102,9 +90,6 @@ spec:
title: Apicurio Registry URL
description: The Apicurio Schema Registry URL
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
avroDatumProvider:
title: Avro Datum Provider
description: How to read data with Avro
@@ -130,8 +115,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
apicurioAuthUsername:
title: Apicurio Registry Auth Username
description: The Username in Keycloak instance securing the Apicurio
Registry
@@ -143,8 +126,6 @@ spec:
format: password
x-descriptors:
- 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.
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 7f008a5a6..dea5bca40 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
@@ -25,7 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -41,16 +40,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -71,16 +64,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
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 02951ba04..2d99711f6 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
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "scram-sha-512"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
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 ed4f260b0..2ee88257c 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
@@ -25,9 +25,6 @@ metadata:
camel.apache.org/provider: "Apache Software Foundation"
camel.apache.org/kamelet.group: "Kafka"
camel.apache.org/kamelet.namespace: "Kafka"
- camel.apache.org/keda.type: "kafka"
- camel.apache.org/keda.authentication.sasl: "plaintext"
- camel.apache.org/keda.authentication.tls: "enable"
labels:
camel.apache.org/kamelet.type: "source"
spec:
@@ -45,16 +42,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
@@ -71,8 +62,6 @@ spec:
type: string
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:username
- - urn:keda:required
password:
title: Password
description: Password to authenticate to kafka
@@ -80,8 +69,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
autoCommitEnable:
title: Auto Commit Enable
description: If true, periodically commit to ZooKeeper the offset of
messages already fetched by the consumer
@@ -102,16 +89,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
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 ee4b5de02..6020b3837 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
@@ -43,16 +43,10 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names.
type: string
- x-descriptors:
- - urn:keda:metadata:topic
- - urn:keda:required
bootstrapServers:
title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs.
type: string
- x-descriptors:
- - urn:keda:metadata:bootstrapServers
- - urn:keda:required
securityProtocol:
title: Security Protocol
description: Protocol used to communicate with brokers.
`SASL_PLAINTEXT`, `PLAINTEXT`, `SASL_SSL` and `SSL` are supported.
@@ -83,16 +77,11 @@ spec:
description: What to do when there is no initial offset. There are 3
enums and the value can be one of latest, earliest, none.
type: string
default: "latest"
- x-descriptors:
- - urn:keda:metadata:offsetResetPolicy
consumerGroup:
title: Consumer Group
description: A string that uniquely identifies the group of consumers
to which this source belongs.
type: string
example: "my-group-id"
- x-descriptors:
- - urn:keda:metadata:consumerGroup
- - urn:keda:required
deserializeHeaders:
title: Automatically Deserialize Headers
description: When enabled the Kamelet source will deserialize all
message headers to String representation.
@@ -103,10 +92,6 @@ spec:
title: SSL Key Password
type: string
format: password
- x-descriptors:
- - urn:camel:group:credentials
- - urn:keda:authentication:password
- - urn:keda:required
sslKeystorePassword:
description: The store password for the key store file.This is
optional for client and only needed if ssl.keystore.location is configured.
title: SSL Keystore Password
@@ -114,7 +99,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
sslEndpointAlgorithm:
description: The endpoint identification algorithm to validate server
hostname using server certificate. Use none or false to disable server hostname
verification.
title: SSL Endpoint Algorithm
@@ -140,7 +124,6 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
- - urn:keda:authentication:password
sslEnabledProtocols:
description: The list of protocols enabled for SSL connections.
TLSv1.2, TLSv1.1 and TLSv1 are enabled by default.
title: SSL Enabled Protocols
diff --git a/script/validator/validator.go b/script/validator/validator.go
index 2a09fda03..3d6ed6b63 100644
--- a/script/validator/validator.go
+++ b/script/validator/validator.go
@@ -388,12 +388,6 @@ func getUsedParams(k camelapiv1.Kamelet) map[string]bool {
}
params := make(map[string]bool)
inspectTemplateParams(templateData, params)
- for propName, propVal := range k.Spec.Definition.Properties {
- if hasXDescriptorPrefix(propVal, "urn:keda:") {
- // Assume KEDA parameters may be used by KEDA
- params[propName] = true
- }
- }
return params
}
return nil
