Package software.amazon.awscdk.services.msk.alpha

Class Cluster

java.lang.Object
software.amazon.jsii.JsiiObject
software.constructs.Construct
software.amazon.awscdk.Resource
software.amazon.awscdk.services.msk.alpha.ClusterBase
software.amazon.awscdk.services.msk.alpha.Cluster
All Implemented Interfaces:
IEnvironmentAware, IResource, IConnectable, ICluster, software.amazon.jsii.JsiiSerializable, software.constructs.IConstruct, software.constructs.IDependable
@Generated(value="jsii-pacmak/1.120.0 (build 192dc88)", date="2025-12-05T22:26:50.246Z") @Stability(Experimental) public class Cluster extends ClusterBase
(experimental) Create a MSK Cluster.

Example: 

 Vpc vpc;
 Cluster cluster = Cluster.Builder.create(this, "cluster")
         .clusterName("myCluster")
         .kafkaVersion(KafkaVersion.V4_1_X_KRAFT)
         .vpc(vpc)
         .encryptionInTransit(EncryptionInTransitConfig.builder()
                 .clientBroker(ClientBrokerEncryption.TLS)
                 .build())
         .clientAuthentication(ClientAuthentication.sasl(SaslAuthProps.builder()
                 .scram(true)
                 .build()))
         .build();

  • Field Details

    • PROPERTY_INJECTION_ID

      @Stability(Experimental) public static final String PROPERTY_INJECTION_ID
      (experimental) Uniquely identifies this class.

  • Constructor Details

    • Cluster

      protected Cluster(software.amazon.jsii.JsiiObjectRef objRef)

    • Cluster

      protected Cluster(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

    • Cluster

      @Stability(Experimental) public Cluster(@NotNull software.constructs.Construct scope, @NotNull String id, @NotNull ClusterProps props)
      Parameters:
      scope - This parameter is required.
      id - This parameter is required.
      props - This parameter is required.

  • Method Details

    • fromClusterArn

      @Stability(Experimental) @NotNull public static ICluster fromClusterArn(@NotNull software.constructs.Construct scope, @NotNull String id, @NotNull String clusterArn)
      (experimental) Reference an existing cluster, defined outside of the CDK code, by name.

      Parameters:
      scope - This parameter is required.
      id - This parameter is required.
      clusterArn - This parameter is required.

    • addUser

      @Stability(Experimental) public void addUser(@NotNull String... usernames)
      (experimental) A list of usersnames to register with the cluster.

      The password will automatically be generated using Secrets Manager and the { username, password } JSON object stored in Secrets Manager as AmazonMSK_username.

      Must be using the SASL/SCRAM authentication mechanism.

      Parameters:
      usernames -
      • username(s) to register with the cluster.
      This parameter is required.

    • getBootstrapBrokers

      @Stability(Experimental) @NotNull public String getBootstrapBrokers()
      (experimental) Get the list of brokers that a client application can use to bootstrap.

      Uses a Custom Resource to make an API call to getBootstrapBrokers using the Javascript SDK

      Returns:
      • A string containing one or more hostname:port pairs.

    • getBootstrapBrokersSaslIam

      @Stability(Experimental) @NotNull public String getBootstrapBrokersSaslIam()
      (experimental) Get the list of brokers that a SASL/IAM authenticated client application can use to bootstrap.

      Uses a Custom Resource to make an API call to getBootstrapBrokers using the Javascript SDK

      Returns:
      • A string containing one or more DNS names (or IP) and TLS port pairs.

    • getBootstrapBrokersSaslScram

      @Stability(Experimental) @NotNull public String getBootstrapBrokersSaslScram()
      (experimental) Get the list of brokers that a SASL/SCRAM authenticated client application can use to bootstrap.

      Uses a Custom Resource to make an API call to getBootstrapBrokers using the Javascript SDK

      Returns:
      • A string containing one or more dns name (or IP) and SASL SCRAM port pairs.

    • getBootstrapBrokersTls

      @Stability(Experimental) @NotNull public String getBootstrapBrokersTls()
      (experimental) Get the list of brokers that a TLS authenticated client application can use to bootstrap.

      Uses a Custom Resource to make an API call to getBootstrapBrokers using the Javascript SDK

      Returns:
      • A string containing one or more DNS names (or IP) and TLS port pairs.

    • getClusterArn

      @Stability(Experimental) @NotNull public String getClusterArn()
      (experimental) The ARN of cluster.
      Specified by:
      getClusterArn in interface ICluster
      Specified by:
      getClusterArn in class ClusterBase

    • getClusterName

      @Stability(Experimental) @NotNull public String getClusterName()
      (experimental) The physical name of the cluster.
      Specified by:
      getClusterName in interface ICluster
      Specified by:
      getClusterName in class ClusterBase

    • getZookeeperConnectionString

      @Stability(Experimental) @NotNull public String getZookeeperConnectionString()
      (experimental) Get the ZooKeeper Connection string.

      Uses a Custom Resource to make an API call to describeCluster using the Javascript SDK

      Returns:
      • The connection string to use to connect to the Apache ZooKeeper cluster.

    • getZookeeperConnectionStringTls

      @Stability(Experimental) @NotNull public String getZookeeperConnectionStringTls()
      (experimental) Get the ZooKeeper Connection string for a TLS enabled cluster.

      Uses a Custom Resource to make an API call to describeCluster using the Javascript SDK

      Returns:
      • The connection string to use to connect to zookeeper cluster on TLS port.

    • getSaslScramAuthenticationKey

      @Stability(Experimental) @Nullable public IKey getSaslScramAuthenticationKey()
      (experimental) Key used to encrypt SASL/SCRAM users.