This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 758ab1fc9609b54ce7c5c86001df099a13a90975 Author: Andrea Cosentino <[email protected]> AuthorDate: Thu Nov 16 09:42:38 2023 +0100 Remove Azure Schema Registry DefaultCredentialWrapper from library - Validation Signed-off-by: Andrea Cosentino <[email protected]> --- .../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);
