This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch kafka-batch-azure in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 792f524ab24ae124826612df02a60e00324e5191 Author: Andrea Cosentino <[email protected]> AuthorDate: Thu Feb 1 12:11:15 2024 +0100 Support Kafka Batch as Kamelet source - Kafka Azure Schema Registry Source as batch Signed-off-by: Andrea Cosentino <[email protected]> --- docs/modules/ROOT/nav.adoc | 1 + script/validator/validator.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc index e62ee0df..32c52e34 100644 --- a/docs/modules/ROOT/nav.adoc +++ b/docs/modules/ROOT/nav.adoc @@ -131,6 +131,7 @@ * xref:kafka-apicurio-registry-not-secured-source.adoc[] * xref:kafka-azure-schema-registry-sink.adoc[] * xref:kafka-azure-schema-registry-source.adoc[] +* xref:kafka-batch-azure-schema-registry-source.adoc[] * xref:kafka-batch-manual-commit-action.adoc[] * xref:kafka-batch-not-secured-source.adoc[] * xref:kafka-batch-scram-source.adoc[] diff --git a/script/validator/validator.go b/script/validator/validator.go index cf62cf5f..e2da1d59 100644 --- a/script/validator/validator.go +++ b/script/validator/validator.go @@ -378,7 +378,7 @@ func listKamelets(dir string) []KameletInfo { func verifyUsedParams(kamelets []KameletInfo) (errors []error) { for _, k := range kamelets { - if k.FileName != "../../kamelets/azure-storage-blob-source.kamelet.yaml" && k.FileName != "../../kamelets/aws-s3-cdc-source.kamelet.yaml" && k.FileName != "../../kamelets/set-kafka-key-action.kamelet.yaml" && k.FileName != "../../kamelets/azure-storage-blob-cdc-source.kamelet.yaml" && k.FileName != "../../kamelets/google-storage-cdc-source.kamelet.yaml" && k.FileName != "../../kamelets/elasticsearch-search-source.kamelet.yaml" && k.FileName != "../../kamelets/opensearch-search-source.k [...] + if k.FileName != "../../kamelets/azure-storage-blob-source.kamelet.yaml" && k.FileName != "../../kamelets/aws-s3-cdc-source.kamelet.yaml" && k.FileName != "../../kamelets/set-kafka-key-action.kamelet.yaml" && k.FileName != "../../kamelets/azure-storage-blob-cdc-source.kamelet.yaml" && k.FileName != "../../kamelets/google-storage-cdc-source.kamelet.yaml" && k.FileName != "../../kamelets/elasticsearch-search-source.kamelet.yaml" && k.FileName != "../../kamelets/opensearch-search-source.k [...] used := getUsedParams(k.Kamelet) declared := getDeclaredParams(k.Kamelet) for p := range used {
