You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2023/11/16 08:57:01 UTC
(camel-kamelets) 03/05: Remove Azure Schema Registry DefaultCredentialWrapper from library - Validation
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 1713
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 6230df36448e70937853d3567cd9541887dad225
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Nov 16 09:42:38 2023 +0100
Remove Azure Schema Registry DefaultCredentialWrapper from library - Validation
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml | 4 ++--
.../kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 4 ++--
.../org/apache/camel/kamelets/maven/plugin/ValidateKameletsMojo.java | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
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 5d69e967..844dea22 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
@@ -90,17 +90,17 @@ spec:
type: string
example: "com.example.Order"
dependencies:
- - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.2.0-SNAPSHOT"
- "camel:core"
- "camel:kafka"
- "camel:kamelet"
+ - "camel:azure-schema-registry"
- "mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.1"
- "mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.11"
- "mvn:com.azure:azure-identity:1.10.4"
template:
beans:
- name: defaultAzureCredential
- type: "#class:org.apache.camel.kamelets.utils.kafka.registry.DefaultAzureCredentialWrapper"
+ type: "#class:org.apache.camel.component.azure.schema.registry.DefaultAzureCredentialWrapper"
from:
uri: "kamelet:source"
steps:
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 feda6866..4a627678 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
@@ -129,17 +129,17 @@ spec:
type: string
example: "com.example.Order"
dependencies:
- - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.2.0-SNAPSHOT"
- "camel:kafka"
- "camel:core"
- "camel:kamelet"
+ - "camel:azure-schema-registry"
- "mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.1"
- "mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.11"
- "mvn:com.azure:azure-identity:1.10.4"
template:
beans:
- name: defaultAzureCredential
- type: "#class:org.apache.camel.kamelets.utils.kafka.registry.DefaultAzureCredentialWrapper"
+ type: "#class:org.apache.camel.component.azure.schema.registry.DefaultAzureCredentialWrapper"
- name: kafkaHeaderDeserializer
type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
properties:
diff --git a/library/kamelets-maven-plugin/src/main/java/org/apache/camel/kamelets/maven/plugin/ValidateKameletsMojo.java b/library/kamelets-maven-plugin/src/main/java/org/apache/camel/kamelets/maven/plugin/ValidateKameletsMojo.java
index 63f3950f..dc93cb82 100644
--- a/library/kamelets-maven-plugin/src/main/java/org/apache/camel/kamelets/maven/plugin/ValidateKameletsMojo.java
+++ b/library/kamelets-maven-plugin/src/main/java/org/apache/camel/kamelets/maven/plugin/ValidateKameletsMojo.java
@@ -112,7 +112,7 @@ public class ValidateKameletsMojo extends AbstractMojo {
StringBuilder availableParams = new StringBuilder();
ceInternal.forEach(_param -> availableParams.append(_param).append(" "));
for (Map.Entry<String, Object> entry : p.entrySet()) {
- if (!entry.getKey().equals("period") && (!name.equals("set-kafka-key-action") && !name.equals("sftp-source") && !name.equals("kafka-ssl-source") && !name.equals("timer-source") && !name.equals("cron-source") && !name.equals("fhir-source") && !name.equals("beer-source") && !name.equals("cassandra-source") && !name.equals("cassandra-sink"))) {
+ if (!entry.getKey().equals("period") && (!name.equals("set-kafka-key-action") && !name.equals("sftp-source") && !name.equals("kafka-ssl-source") && !name.equals("timer-source") && !name.equals("cron-source") && !name.equals("fhir-source") && !name.equals("beer-source") && !name.equals("cassandra-source") && !name.equals("cassandra-sink") && !name.equals("kafka-azure-schema-registry-source" ) && !name.equals("kafka-azure-schema-registy-sink"))) {
if (!ceInternal.contains(entry.getKey())) {
getLog().error("Kamelet Name: " + name);
getLog().error("Scheme Name: " + cleanName);