-
Type:
Improvement
-
Resolution: Cannot Reproduce
-
Priority:
Major - P3
-
None
-
Affects Version/s: 1.0
-
Component/s: None
-
None
-
Environment:kafka connect 5.3.1
-
None
-
None
-
None
-
None
-
None
-
None
-
None
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.