Experimental
@aws-cdk/aws-msk-alpha is an experimental (alpha) package: its API may change in any release, without a major version bump.
ClusterProps Struct
Properties for a MSK Cluster.
Example
declare const vpc: ec2.Vpc;
const cluster = new msk.Cluster(this, 'cluster', {
clusterName: 'myCluster',
kafkaVersion: msk.KafkaVersion.V4_1_X_KRAFT,
vpc,
encryptionInTransit: {
clientBroker: msk.ClientBrokerEncryption.TLS,
},
clientAuthentication: msk.ClientAuthentication.sasl({
scram: true,
}),
});
Properties
brokerTypeoptionalBrokerTypebroker_typeoptionalBrokerTypebrokerTypeoptionalBrokerTypeBrokerTypeoptionalBrokerTypeBrokerTypeoptionalBrokerType= BrokerType.STANDARD#When set to EXPRESS, the cluster will be created with Express Brokers. When this is set to EXPRESS, instanceType must also be specified.
clientAuthenticationoptionalClientAuthenticationclient_authenticationoptionalClientAuthenticationclientAuthenticationoptionalClientAuthenticationClientAuthenticationoptionalClientAuthenticationClientAuthenticationoptionalClientAuthentication= disabled#MSK supports using private TLS certificates or SASL/SCRAM to authenticate the identity of clients.
configurationInfooptionalClusterConfigurationInfoconfiguration_infooptionalClusterConfigurationInfoconfigurationInfooptionalClusterConfigurationInfoConfigurationInfooptionalClusterConfigurationInfoConfigurationInfooptionalClusterConfigurationInfo= none#ebsStorageInfooptionalEbsStorageInfoebs_storage_infooptionalEbsStorageInfoebsStorageInfooptionalEbsStorageInfoEbsStorageInfooptionalEbsStorageInfoEbsStorageInfooptionalEbsStorageInfo#Default: 1000 GiB EBS volume
encryptionInTransitoptionalEncryptionInTransitConfigencryption_in_transitoptionalEncryptionInTransitConfigencryptionInTransitoptionalEncryptionInTransitConfigEncryptionInTransitoptionalEncryptionInTransitConfigEncryptionInTransitoptionalEncryptionInTransitConfig= enabled#instanceTypeoptionalInstanceTypeinstance_typeoptionalInstanceTypeinstanceTypeoptionalInstanceTypeInstanceTypeoptionalInstanceTypeInstanceTypeoptionalInstanceType= kafka.m5.large#kafkaVersionKafkaVersionkafka_versionKafkaVersionkafkaVersionKafkaVersionKafkaVersionKafkaVersionKafkaVersionKafkaVersionrequired#loggingoptionalBrokerLoggingloggingoptionalBrokerLoggingloggingoptionalBrokerLoggingLoggingoptionalBrokerLoggingLoggingoptionalBrokerLogging= disabled#monitoringoptionalMonitoringConfigurationmonitoringoptionalMonitoringConfigurationmonitoringoptionalMonitoringConfigurationMonitoringoptionalMonitoringConfigurationMonitoringoptionalMonitoringConfiguration#Default: DEFAULT monitoring level
numberOfBrokerNodesoptionalnumbernumber_of_broker_nodesoptionalint | floatnumberOfBrokerNodesoptionalNumberNumberOfBrokerNodesoptionaldoubleNumberOfBrokerNodesoptional*float64= 1#removalPolicyoptionalRemovalPolicyremoval_policyoptionalRemovalPolicyremovalPolicyoptionalRemovalPolicyRemovalPolicyoptionalRemovalPolicyRemovalPolicyoptionalRemovalPolicy= RemovalPolicy.RETAIN#securityGroupsoptionalISecurityGroup[]security_groupsoptionaltyping.List[ISecurityGroup]securityGroupsoptionalList<ISecurityGroup>SecurityGroupsoptionalISecurityGroup[]SecurityGroupsoptional*[]ISecurityGroup#Default: create new security group
storageModeoptionalStorageModestorage_modeoptionalStorageModestorageModeoptionalStorageModeStorageModeoptionalStorageModeStorageModeoptionalStorageMode= StorageMode.LOCAL#Must have at least 2 subnets in two different AZs.
vpcSubnetsoptionalSubnetSelectionvpc_subnetsoptionalSubnetSelectionvpcSubnetsoptionalSubnetSelectionVpcSubnetsoptionalSubnetSelectionVpcSubnetsoptionalSubnetSelection#Default: the Vpc default strategy if not specified.
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.