Class ClusterLinkAccessTokenRetrieverFactory

java.lang.Object
io.confluent.kafka.clients.plugins.auth.oauth.ClusterLinkAccessTokenRetrieverFactory
public class ClusterLinkAccessTokenRetrieverFactory extends Object

  • Constructor Details

    • ClusterLinkAccessTokenRetrieverFactory

      public ClusterLinkAccessTokenRetrieverFactory()

  • Method Details

    • create

      public static org.apache.kafka.common.security.oauthbearer.JwtRetriever create(Map<String,?> configs, Map<String,Object> jaasConfig)
      Create a JwtRetriever from the given SASL and JAAS configuration. Note: the returned JwtRetriever is not initialized here and must be done by the caller prior to use.
      Parameters:
      configs - SASL configuration
      jaasConfig - JAAS configuration
      Returns:
      Non-null JwtRetriever

    • create

      public static org.apache.kafka.common.security.oauthbearer.JwtRetriever create(Map<String,?> configs, String saslMechanism, Map<String,Object> jaasConfig)