OAUTHBEARER SASL support?

[ciaran-moore]

Is there a way of authorising using OAuth2? I have checked the code but can't seem to find any instances of oauthbearer within the header files to be able to set the token, or initialise the token refresh callback.

The callback function rd_kafka_conf_set_oauthbearer_token_refresh_cb also requires an rd_kafka_conf_t argument to the function, is there a way to return this from the kafka::Properties? or would I need to set all this through the librdkafka functions?

i.e. kafka::Properties object for non-oauth based configuration and a separate rd_kafka_conf_t variable to do the Oauth parts?