This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-apicurio-json-schema
in repository https://gitbox.apache.org/repos/asf/camel-kamelets-examples.git
commit d3631780bf743de089b7fbc62be99b75df1d4993
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed May 15 10:04:40 2024 +0200
Added an example of Kafka + Apicurio Registry secured with Keycloak and
Json Schema validation
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
jbang/kafka-apicurio-secured-json-schema-registry/README.md | 2 +-
.../kafka-not-secured-apicurio-registry-json-source.kamelet.yaml | 6 ------
2 files changed, 1 insertion(+), 7 deletions(-)
diff --git a/jbang/kafka-apicurio-secured-json-schema-registry/README.md
b/jbang/kafka-apicurio-secured-json-schema-registry/README.md
index 854f9be..bf3fdcb 100644
--- a/jbang/kafka-apicurio-secured-json-schema-registry/README.md
+++ b/jbang/kafka-apicurio-secured-json-schema-registry/README.md
@@ -140,7 +140,7 @@ You should see something like
2024-05-15 09:36:38.372 INFO 24390 --- [ main]
e.camel.impl.engine.AbstractCamelContext : Routes startup (total:1 started:1
kamelets:2)
2024-05-15 09:36:38.372 INFO 24390 --- [ main]
e.camel.impl.engine.AbstractCamelContext : Started kafka-to-apicurio-log
(kamelet://kafka-not-secured-apicurio-registry-json-source)
2024-05-15 09:36:38.373 INFO 24390 --- [ main]
e.camel.impl.engine.AbstractCamelContext : Apache Camel 4.6.0
(kafka-apicurio-kamelet) started in 217ms (build:0ms init:0ms start:217ms)
-2024-05-15 09:36:38.669 INFO 24390 --- [[product-topic]]
he.kafka.clients.consumer.ConsumerConfig : These configurations
'[retry.backoff.max.ms, apicurio.registry.avroDatumProvider,
apicurio.auth.service.url, apicurio.auth.realm, apicurio.auth.password,
apicurio.auth.client.id, apicurio.auth.client.secret, apicurio.registry.url,
apicurio.auth.username]' were supplied but are not used yet.
+2024-05-15 09:36:38.669 INFO 24390 --- [[product-topic]]
he.kafka.clients.consumer.ConsumerConfig : These configurations
'[retry.backoff.max.ms, apicurio.auth.service.url, apicurio.auth.realm,
apicurio.auth.password, apicurio.auth.client.id, apicurio.auth.client.secret,
apicurio.registry.url, apicurio.auth.username]' were supplied but are not used
yet.
2024-05-15 09:36:38.670 INFO 24390 --- [[product-topic]]
.apache.kafka.common.utils.AppInfoParser : Kafka version: 3.5.1
2024-05-15 09:36:38.670 INFO 24390 --- [[product-topic]]
.apache.kafka.common.utils.AppInfoParser : Kafka commitId: 2c6fb6c54472e90a
2024-05-15 09:36:38.670 INFO 24390 --- [[product-topic]]
.apache.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1715758598669
diff --git
a/jbang/kafka-apicurio-secured-json-schema-registry/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
b/jbang/kafka-apicurio-secured-json-schema-registry/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
index 588124d..ac4b6cf 100644
---
a/jbang/kafka-apicurio-secured-json-schema-registry/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
+++
b/jbang/kafka-apicurio-secured-json-schema-registry/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
@@ -106,11 +106,6 @@ spec:
x-descriptors:
- urn:keda:metadata:bootstrapServers
- urn:keda:required
- avroDatumProvider:
- title: Avro Datum Provider
- description: How to read data with Avro
- type: string
- default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
apicurioAuthServiceUrl:
title: Apicurio Registry Auth Service URL
description: The URL for Keycloak instance securing the Apicurio
Registry
@@ -175,7 +170,6 @@ spec:
valueDeserializer: "{{valueDeserializer}}"
topicIsPattern: "{{topicIsPattern}}"
additionalProperties.apicurio.registry.url: "{{apicurioRegistryUrl}}"
- additionalProperties.apicurio.registry.avro-datum-provider:
"{{avroDatumProvider}}"
additionalProperties.apicurio.auth.service.url:
"{{apicurioAuthServiceUrl}}"
additionalProperties.apicurio.auth.realm: "{{apicurioAuthRealm}}"
additionalProperties.apicurio.auth.client.id:
"{{apicurioAuthClientId}}"
