public static final class ClusterProps.Builder
extends java.lang.Object
ClusterProps
Constructor and Description |
---|
Builder() |
public ClusterProps.Builder clusterName(java.lang.String clusterName)
ClusterProps.getClusterName()
clusterName
- The physical name of the cluster. This parameter is required.this
public ClusterProps.Builder kafkaVersion(KafkaVersion kafkaVersion)
ClusterProps.getKafkaVersion()
kafkaVersion
- The version of Apache Kafka. This parameter is required.this
public ClusterProps.Builder vpc(IVpc vpc)
ClusterProps.getVpc()
vpc
- Defines the virtual networking environment for this cluster. This parameter is required.
Must have at least 2 subnets in two different AZs.this
public ClusterProps.Builder clientAuthentication(ClientAuthentication clientAuthentication)
ClusterProps.getClientAuthentication()
clientAuthentication
- Configuration properties for client authentication.
MSK supports using private TLS certificates or SASL/SCRAM to authenticate the identity of clients.this
public ClusterProps.Builder configurationInfo(ClusterConfigurationInfo configurationInfo)
ClusterProps.getConfigurationInfo()
configurationInfo
- The Amazon MSK configuration to use for the cluster.this
public ClusterProps.Builder ebsStorageInfo(EbsStorageInfo ebsStorageInfo)
ClusterProps.getEbsStorageInfo()
ebsStorageInfo
- Information about storage volumes attached to MSK broker nodes.this
public ClusterProps.Builder encryptionInTransit(EncryptionInTransitConfig encryptionInTransit)
ClusterProps.getEncryptionInTransit()
encryptionInTransit
- Config details for encryption in transit.this
public ClusterProps.Builder instanceType(InstanceType instanceType)
ClusterProps.getInstanceType()
instanceType
- The EC2 instance type that you want Amazon MSK to use when it creates your brokers.this
public ClusterProps.Builder logging(BrokerLogging logging)
ClusterProps.getLogging()
logging
- Configure your MSK cluster to send broker logs to different destination types.this
public ClusterProps.Builder monitoring(MonitoringConfiguration monitoring)
ClusterProps.getMonitoring()
monitoring
- Cluster monitoring configuration.this
public ClusterProps.Builder numberOfBrokerNodes(java.lang.Number numberOfBrokerNodes)
ClusterProps.getNumberOfBrokerNodes()
numberOfBrokerNodes
- Number of Apache Kafka brokers deployed in each Availability Zone.this
public ClusterProps.Builder removalPolicy(RemovalPolicy removalPolicy)
ClusterProps.getRemovalPolicy()
removalPolicy
- What to do when this resource is deleted from a stack.this
public ClusterProps.Builder securityGroups(java.util.List<? extends ISecurityGroup> securityGroups)
ClusterProps.getSecurityGroups()
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
public ClusterProps.Builder vpcSubnets(SubnetSelection vpcSubnets)
ClusterProps.getVpcSubnets()
vpcSubnets
- Where to place the nodes within the VPC.
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.this
public ClusterProps build()
ClusterProps
java.lang.NullPointerException
- if any required attribute was not provided