Details
-
Improvement
-
Resolution: Cannot Reproduce
-
Major - P3
-
None
-
1.0
-
None
-
None
-
kafka connect 5.3.1
Description
hi,
We are using Mongo Sink with the schema registry.
The schema registry authentication is handle by the kafka connect instance thanks to the related keys :
|
key.converter.schema.registry.url=xxx
|
key.converter.basic.auth.credentials.source=USER_INFO
|
key.converter.basic.auth.user.info=xxx
|
|
|
value.converter.schema.registry.url=xxx
|
value.converter.basic.auth.credentials.source=USER_INFO
|
value.converter.basic.auth.user.info=xxx
|
|
When deploying a mongo-sink configuration, if we not add thoses keys, connect throws an Unauthorized exception when trying to get key and value schemas from registry.
With others connectors like sftp connect (provided by Confluent), this configuration is induced from kafka-connect configuration listed below.
It will be nice that the Mongo connector hava the same behavior.