Modifier and Type | Method and Description |
---|---|
Cluster |
build() |
Cluster.Builder |
clientAuthentication(ClientAuthentication clientAuthentication)
(experimental) Configuration properties for client authentication.
|
Cluster.Builder |
clusterName(java.lang.String clusterName)
(experimental) The physical name of the cluster.
|
Cluster.Builder |
configurationInfo(ClusterConfigurationInfo configurationInfo)
(experimental) The Amazon MSK configuration to use for the cluster.
|
static Cluster.Builder |
create(software.constructs.Construct scope,
java.lang.String id) |
Cluster.Builder |
ebsStorageInfo(EbsStorageInfo ebsStorageInfo)
(experimental) Information about storage volumes attached to MSK broker nodes.
|
Cluster.Builder |
encryptionInTransit(EncryptionInTransitConfig encryptionInTransit)
(experimental) Config details for encryption in transit.
|
Cluster.Builder |
instanceType(InstanceType instanceType)
(experimental) The EC2 instance type that you want Amazon MSK to use when it creates your brokers.
|
Cluster.Builder |
kafkaVersion(KafkaVersion kafkaVersion)
(experimental) The version of Apache Kafka.
|
Cluster.Builder |
logging(BrokerLogging logging)
(experimental) Configure your MSK cluster to send broker logs to different destination types.
|
Cluster.Builder |
monitoring(MonitoringConfiguration monitoring)
(experimental) Cluster monitoring configuration.
|
Cluster.Builder |
numberOfBrokerNodes(java.lang.Number numberOfBrokerNodes)
(experimental) Number of Apache Kafka brokers deployed in each Availability Zone.
|
Cluster.Builder |
removalPolicy(RemovalPolicy removalPolicy)
(experimental) What to do when this resource is deleted from a stack.
|
Cluster.Builder |
securityGroups(java.util.List<? extends ISecurityGroup> securityGroups)
(experimental) The AWS security groups to associate with the elastic network interfaces in order to specify who can connect to and communicate with the Amazon MSK cluster.
|
Cluster.Builder |
vpc(IVpc vpc)
(experimental) Defines the virtual networking environment for this cluster.
|
Cluster.Builder |
vpcSubnets(SubnetSelection vpcSubnets)
(experimental) Where to place the nodes within the VPC.
|
public static Cluster.Builder create(software.constructs.Construct scope, java.lang.String id)
scope
- This parameter is required.id
- This parameter is required.Cluster.Builder
.public Cluster.Builder clusterName(java.lang.String clusterName)
clusterName
- The physical name of the cluster. This parameter is required.this
public Cluster.Builder kafkaVersion(KafkaVersion kafkaVersion)
kafkaVersion
- The version of Apache Kafka. This parameter is required.this
public Cluster.Builder vpc(IVpc vpc)
Must have at least 2 subnets in two different AZs.
vpc
- Defines the virtual networking environment for this cluster. This parameter is required.this
public Cluster.Builder clientAuthentication(ClientAuthentication clientAuthentication)
MSK supports using private TLS certificates or SASL/SCRAM to authenticate the identity of clients.
Default: - disabled
clientAuthentication
- Configuration properties for client authentication. This parameter is required.this
public Cluster.Builder configurationInfo(ClusterConfigurationInfo configurationInfo)
Default: - none
configurationInfo
- The Amazon MSK configuration to use for the cluster. This parameter is required.this
public Cluster.Builder ebsStorageInfo(EbsStorageInfo ebsStorageInfo)
Default: - 1000 GiB EBS volume
ebsStorageInfo
- Information about storage volumes attached to MSK broker nodes. This parameter is required.this
public Cluster.Builder encryptionInTransit(EncryptionInTransitConfig encryptionInTransit)
Default: - enabled
encryptionInTransit
- Config details for encryption in transit. This parameter is required.this
public Cluster.Builder instanceType(InstanceType instanceType)
Default: kafka.m5.large
instanceType
- The EC2 instance type that you want Amazon MSK to use when it creates your brokers. This parameter is required.this
public Cluster.Builder logging(BrokerLogging logging)
Default: - disabled
logging
- Configure your MSK cluster to send broker logs to different destination types. This parameter is required.this
public Cluster.Builder monitoring(MonitoringConfiguration monitoring)
Default: - DEFAULT monitoring level
monitoring
- Cluster monitoring configuration. This parameter is required.this
public Cluster.Builder numberOfBrokerNodes(java.lang.Number numberOfBrokerNodes)
Default: 1
numberOfBrokerNodes
- Number of Apache Kafka brokers deployed in each Availability Zone. This parameter is required.this
public Cluster.Builder removalPolicy(RemovalPolicy removalPolicy)
Default: RemovalPolicy.RETAIN
removalPolicy
- What to do when this resource is deleted from a stack. This parameter is required.this
public Cluster.Builder securityGroups(java.util.List<? extends ISecurityGroup> securityGroups)
Default: - create new security group
securityGroups
- The AWS security groups to associate with the elastic network interfaces in order to specify who can connect to and communicate with the Amazon MSK cluster. This parameter is required.this
public Cluster.Builder vpcSubnets(SubnetSelection vpcSubnets)
Amazon MSK distributes the broker nodes evenly across the subnets that you specify. The subnets that you specify must be in distinct Availability Zones. Client subnets can't be in Availability Zone us-east-1e.
Default: - the Vpc default strategy if not specified.
vpcSubnets
- Where to place the nodes within the VPC. This parameter is required.this
public Cluster build()