Hello 

Can anyone point me in the right direction for how to configure auth settings 
for Confluent schema registry with the Kafka component ? 

 

I checked the code [1] and I see “schemaRegistryUrl” but no authentications 
option for it.

 

I suspect I need “schema.registry.basic.auth.user.info” and 
“basic.auth.credentials.source” settings when using the Camel Kafka component 
with the special Confluent schemaRegistryUrl setting [2]? 

 

This config works locally with no authentication but I am not seeing how to 
include authentication for confluent.cloud:

 

kafka:my.topic.name?schemaRegistryURL=http://localhost:9080

&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer

&valueDeserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer

&specificAvroReader=true

&brokers=localhost:9092

&securityProtocol=SASL_SSL

&saslMechanism=PLAIN

&saslJaasConfig=RAW(org.apache.kafka.common.security.plain.PlainLoginModule 
required username="my-username" password="my-password/has slashes";)

 

-Jeff

 

[1] 
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java

[2] 
https://camel.apache.org/components/3.18.x/kafka-component.html#_component_option_schemaRegistryURL

 

See also: 
https://stackoverflow.com/questions/58835635/how-pass-basic-authentication-to-confluent-schema-registry

 

Reply via email to