Class GcpBearerAuthCredentialProvider

java.lang.Object
com.google.cloud.hosted.kafka.auth.GcpBearerAuthCredentialProvider
All Implemented Interfaces:
io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class GcpBearerAuthCredentialProvider extends Object implements io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider
A Bearer Auth Credential Provider that provides a Google OAuth token to a Schema Registry client.

This callback handler is used by the Schema Registry client to authenticate to a Google's Schema Registry server using OAuth.

  • Constructor Details

    • GcpBearerAuthCredentialProvider

      public GcpBearerAuthCredentialProvider()
      Creates a new credential provider using the default application credentials.
    • GcpBearerAuthCredentialProvider

      public GcpBearerAuthCredentialProvider(com.google.auth.oauth2.GoogleCredentials credentials)
  • Method Details

    • alias

      public String alias()
      Specified by:
      alias in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider
    • getTargetSchemaRegistry

      public String getTargetSchemaRegistry()
      Specified by:
      getTargetSchemaRegistry in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider
    • getTargetIdentityPoolId

      public String getTargetIdentityPoolId()
      Specified by:
      getTargetIdentityPoolId in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider
    • getBearerToken

      public String getBearerToken(URL url)
      Specified by:
      getBearerToken in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider
    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable