java.lang.Object
io.confluent.kafka.schemaregistry.encryption.alicloud.AliCloudKmsClient
All Implemented Interfaces:
com.google.crypto.tink.KmsClient

public final class AliCloudKmsClient extends Object implements com.google.crypto.tink.KmsClient
  • Field Details

  • Constructor Details

    • AliCloudKmsClient

      public AliCloudKmsClient()
      Constructs a generic AliCloudKmsClient that is not bound to any specific key.
    • AliCloudKmsClient

      public AliCloudKmsClient(String uri)
      Constructs an AliCloudKmsClient that is bound to a single key identified by uri.
    • AliCloudKmsClient

      public AliCloudKmsClient(Map<String,?> configs, Optional<String> kekUrl) throws GeneralSecurityException
      Throws:
      GeneralSecurityException
  • Method Details

    • doesSupport

      public boolean doesSupport(String uri)
      Specified by:
      doesSupport in interface com.google.crypto.tink.KmsClient
    • withCredentials

      public com.google.crypto.tink.KmsClient withCredentials(String credentialPath) throws GeneralSecurityException
      Specified by:
      withCredentials in interface com.google.crypto.tink.KmsClient
      Throws:
      GeneralSecurityException
    • withDefaultCredentials

      public com.google.crypto.tink.KmsClient withDefaultCredentials()
      Specified by:
      withDefaultCredentials in interface com.google.crypto.tink.KmsClient
    • getAead

      public com.google.crypto.tink.Aead getAead(String uri) throws GeneralSecurityException
      Specified by:
      getAead in interface com.google.crypto.tink.KmsClient
      Throws:
      GeneralSecurityException
    • register

      public static void register(Optional<String> keyUri, Optional<String> credentialPath) throws GeneralSecurityException
      Creates and registers an Alibaba Cloud KMS client with the Tink runtime.
      Throws:
      GeneralSecurityException