Experimental
@aws-cdk/aws-msk-alpha is an experimental (alpha) package: its API may change in any release, without a major version bump.
StorageMode Enum
The storage mode for the cluster brokers.
Example
ts
declare const vpc: ec2.Vpc;
declare const bucket: s3.IBucket;
const cluster = new msk.Cluster(this, 'cluster', {
clusterName: 'myCluster',
kafkaVersion: msk.KafkaVersion.V4_1_X_KRAFT,
vpc,
storageMode: msk.StorageMode.TIERED,
});
python
# vpc: ec2.Vpc
# bucket: s3.IBucket
cluster = msk.Cluster(self, "cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V4_1_X_KRAFT,
vpc=vpc,
storage_mode=msk.StorageMode.TIERED
)
java
Vpc vpc;
IBucket bucket;
Cluster cluster = Cluster.Builder.create(this, "cluster")
.clusterName("myCluster")
.kafkaVersion(KafkaVersion.V4_1_X_KRAFT)
.vpc(vpc)
.storageMode(StorageMode.TIERED)
.build();
csharp
// Install: dotnet add package Amazon.CDK.AWS.MSK.Alpha
Vpc vpc;
IBucket bucket;
var cluster = new Cluster(this, "cluster", new ClusterProps {
ClusterName = "myCluster",
KafkaVersion = KafkaVersion.V4_1_X_KRAFT,
Vpc = vpc,
StorageMode = StorageMode.TIERED
});
go
// Install: go get github.com/aws/aws-cdk-go/awscdkmskalpha/v2
var vpc Vpc
var bucket IBucket
cluster := msk.NewCluster(this, jsii.String("cluster"), &ClusterProps{
ClusterName: jsii.String("myCluster"),
KafkaVersion: msk.KafkaVersion_V4_1_X_KRAFT(),
Vpc: Vpc,
StorageMode: msk.StorageMode_TIERED,
})
Members
| Member | Description |
|---|---|
LOCAL | Local storage mode utilizes network attached EBS storage. |
TIERED | Tiered storage mode utilizes EBS storage and Tiered storage. |
Referenced by
ClusterProps.storageModestorage_modestorageModeStorageModeStorageMode