Class KafkaOAuthCallback

• Defined in File kafka_source.hpp

Base Type

• public RdKafka::OAuthBearerTokenRefreshCb

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