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