Class KafkaOAuthCallback

• Defined in File kafka_source.hpp

Inheritance Relationships

Base Type

• public RdKafka::OAuthBearerTokenRefreshCb

Class Documentation

class KafkaOAuthCallback : public RdKafka::OAuthBearerTokenRefreshCb

Public Functions

KafkaOAuthCallback(

const std::function<std::map<std::string, std::string>()> &oauth_callback

)

void oauthbearer_token_refresh_cb(

RdKafka::Handle *handle,

const std::string &oauthbearer_config

) override