cannot set needed properties to use SASL_SSL with OAUTHBEARER

[vpipkt]

Connector Name

source-kafka

Connector Version

0.2.7

What step the error happened?

During the sync

Relevant information

To connect to Confluent Cloud Kafka broker, I need to use SASL_SSL protocol with OAUTHBEARER Mechanism. In order to do this, I need a way to set the property sasl.oauthbearer.token.endpoint.url so that the request for a token goes to my identity provider. This property is not exposed in connector setup for the protocol/mechanism. I also would like to set the properties sasl.login.callback.handler.class bearer.auth.credentials.source and bearer.auth.logical.cluster so that the OAuth token can be used for the Confluent schema registry as well.

A possible solution might be to expose some properties like the endpoint url as its own text field, and others as a free text where properties can be set by key and value

Relevant log output

partial output from log lines

 INFO o.a.k.c.c.AbstractConfig(logAll):376 KafkaAvroDeserializerConfig values: 
        sasl.client.callback.handler.class = null
	sasl.jaas.config = [hidden]
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.oauthbearer.scope.claim.name = scope
	sasl.oauthbearer.sub.claim.name = sub
	sasl.oauthbearer.token.endpoint.url = null

Contribute

• Yes, I want to contribute