Skip to content
v2.275.0

Amazon Managed Streaming for Apache Kafka Construct Library ​

This module is part of the AWS Cloud Development Kit project.

ts
import * as msk from 'aws-cdk-lib/aws-msk';
python
import aws_cdk.aws_msk as msk
java
import software.amazon.awscdk.services.msk.*;
csharp
using Amazon.CDK.AWS.MSK;
go
import msk "github.com/aws/aws-cdk-go/awscdk"

There are no official hand-written (L2) constructs for this service yet. Here are some suggestions on how to proceed:

An experimental construct library for this service is available in preview. Since it is not stable yet, it is distributed as a separate package so that you can pin its version independently of the rest of the CDK. See the package:

<span class="package-reference">@aws-cdk/aws-msk-alpha</span>

There are no hand-written (L2) constructs for this service yet. However, you can still use the automatically generated L1 constructs, and use this service exactly as you would using CloudFormation directly.

For more information on the resources and properties available for this service, see the CloudFormation documentation for AWS::MSK.

(Read the CDK Contributing Guide and submit an RFC if you are interested in contributing to this construct library.)

Types ​

NameKindSummary
CfnBatchScramSecretConstruct (L1)Represents a secret stored in the AWS Secrets Manager that can be used to authenticate with a cluster using a user name and a password.
CfnChannelConstruct (L1)Resource Type definition for AWS::MSK::Channel.
CfnClusterConstruct (L1)Creates a new MSK cluster.
CfnClusterPolicyConstruct (L1)Create or update cluster policy.
CfnConfigurationConstruct (L1)Creates a new MSK configuration.
CfnReplicatorConstruct (L1)Creates the replicator.
CfnServerlessClusterConstruct (L1)Specifies the properties required for creating a serverless cluster.
CfnTopicConstruct (L1)Resource Type definition for AWS::MSK::Topic.
CfnVpcConnectionConstruct (L1)Create remote VPC connection.
CfnBatchScramSecretPropsStructProperties for defining a CfnBatchScramSecret.
CfnChannel.CatalogPropertyStructCatalog configuration of the destination.
CfnChannel.ChannelLoggingInfoPropertyStructLog configuration details for Channel.
CfnChannel.ChannelStateInfoPropertyStructIncludes information about the channel state.
CfnChannel.CloudWatchLogsLogDestinationPropertyStructCloudWatch Logs log destination details.
CfnChannel.DeadLetterQueueS3PropertyStructDead letter queue S3 configuration of the destination.
CfnChannel.DestinationTablePropertyStructDestination table configuration.
CfnChannel.EncryptionConfigurationPropertyStructEncryption configuration.
CfnChannel.FirehoseLogDestinationPropertyStructFirehose log destination details.
CfnChannel.IcebergDestinationConfigurationPropertyStructIceberg destination configuration.
CfnChannel.PartitionSourcePropertyStructPartition source configuration.
CfnChannel.PartitionSpecPropertyStructPartition specification.
CfnChannel.RecordConverterPropertyStructRecord converter configuration for a topic.
CfnChannel.RecordSchemaPropertyStructRecord schema configuration for a topic.
CfnChannel.S3DestinationConfigurationPropertyStructS3 destination configuration.
CfnChannel.S3LogDestinationPropertyStructS3 log destination details.
CfnChannel.S3StoragePropertyStructS3 storage configuration.
CfnChannel.SchemaEvolutionPropertyStructSchema evolution configuration of the destination.
CfnChannel.TableCreationPropertyStructTable creation configuration of the destination.
CfnChannel.TopicConfigurationPropertyStructConfiguration of topic in a channel.
CfnChannelPropsStructProperties for defining a CfnChannel.
CfnCluster.AuthorizerLogsPropertyStruct
CfnCluster.BrokerLogsPropertyStructThe broker logs configuration for this MSK cluster.
CfnCluster.BrokerNodeGroupInfoPropertyStructDescribes the setup to be used for the broker nodes in the cluster.
CfnCluster.ClientAuthenticationPropertyStruct
CfnCluster.CloudWatchLogsPropertyStructDetails of the CloudWatch Logs destination for broker logs.
CfnCluster.ConfigurationInfoPropertyStructSpecifies the configuration to use for the brokers.
CfnCluster.ConnectivityInfoPropertyStructBroker access controls.
CfnCluster.EBSStorageInfoPropertyStructContains information about the EBS storage volumes attached to the broker nodes.
CfnCluster.EncryptionAtRestPropertyStructThe data-volume encryption details.
CfnCluster.EncryptionInfoPropertyStructIncludes encryption-related information, such as the Amazon KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit.
CfnCluster.EncryptionInTransitPropertyStructThe settings for encrypting data in transit.
CfnCluster.FirehosePropertyStructFirehose details for BrokerLogs.
CfnCluster.IamPropertyStructDetails for SASL/IAM client authentication.
CfnCluster.JmxExporterPropertyStructIndicates whether you want to enable or disable the JMX Exporter.
CfnCluster.LoggingInfoPropertyStructYou can configure your MSK cluster to send broker logs to different destination types.
CfnCluster.NodeExporterPropertyStructIndicates whether you want to enable or disable the Node Exporter.
CfnCluster.OpenMonitoringPropertyStructJMX and Node monitoring for the MSK cluster.
CfnCluster.PrometheusPropertyStructPrometheus settings for open monitoring.
CfnCluster.ProvisionedThroughputPropertyStructContains information about provisioned throughput for EBS storage volumes attached to kafka broker nodes.
CfnCluster.PublicAccessPropertyStructBroker access controls.
CfnCluster.RebalancingPropertyStruct
CfnCluster.S3PropertyStructThe details of the Amazon S3 destination for broker logs.
CfnCluster.SaslPropertyStructDetails for client authentication using SASL.
CfnCluster.ScramPropertyStructDetails for SASL/SCRAM client authentication.
CfnCluster.StorageInfoPropertyStructContains information about storage volumes attached to Amazon MSK broker nodes.
CfnCluster.TlsPropertyStructDetails for client authentication using TLS.
CfnCluster.UnauthenticatedPropertyStructDetails for allowing no client authentication.
CfnCluster.VpcConnectivityClientAuthenticationPropertyStructIncludes all client authentication information for VpcConnectivity.
CfnCluster.VpcConnectivityIamPropertyStructDetails for SASL/IAM client authentication for VpcConnectivity.
CfnCluster.VpcConnectivityPropertyStructVPC connection control settings for brokers.
CfnCluster.VpcConnectivitySaslPropertyStructDetails for client authentication using SASL for VpcConnectivity.
CfnCluster.VpcConnectivityScramPropertyStructDetails for SASL/SCRAM client authentication for VpcConnectivity.
CfnCluster.VpcConnectivityTlsPropertyStructDetails for client authentication using TLS for VpcConnectivity.
CfnCluster.ZookeeperAccessPropertyStruct
CfnClusterPolicyPropsStructProperties for defining a CfnClusterPolicy.
CfnClusterPropsStructProperties for defining a CfnCluster.
CfnConfiguration.LatestRevisionPropertyStructDescribes a configuration revision.
CfnConfigurationPropsStructProperties for defining a CfnConfiguration.
CfnReplicator.AmazonMskClusterPropertyStructDetails of an Amazon MSK Cluster.
CfnReplicator.ApacheKafkaClusterPropertyStructDetails of an Apache Kafka cluster.
CfnReplicator.CloudWatchLogsPropertyStructDetails about delivering logs to CloudWatch Logs.
CfnReplicator.ConsumerGroupReplicationPropertyStructDetails about consumer group replication.
CfnReplicator.FirehosePropertyStructDetails about delivering logs to Firehose.
CfnReplicator.KafkaClusterClientAuthenticationPropertyStructDetails of the client authentication used by the Apache Kafka cluster.
CfnReplicator.KafkaClusterClientVpcConfigPropertyStructDetails of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
CfnReplicator.KafkaClusterEncryptionInTransitPropertyStructDetails of encryption in transit to the Apache Kafka cluster.
CfnReplicator.KafkaClusterMtlsAuthenticationPropertyStructDetails for mTLS client authentication.
CfnReplicator.KafkaClusterOAuthClientCredentialsAssertionPropertyStructDetails for SASL/OAUTHBEARER using the client credentials grant with a JWT client assertion (RFC 7521/7523 Section 2.2). An STS-vended JWT is used as the client_assertion.
CfnReplicator.KafkaClusterOAuthClientCredentialsPropertyStructDetails for SASL/OAUTHBEARER using the standard client_credentials grant.
CfnReplicator.KafkaClusterOAuthIamJwtBearerPropertyStructDetails for SASL/OAUTHBEARER using the JWT Bearer assertion grant (RFC 7523).
CfnReplicator.KafkaClusterPropertyStructInformation about Kafka Cluster to be used as source / target for replication.
CfnReplicator.KafkaClusterSaslOAuthBearerAuthenticationPropertyStructDetails for client authentication using SASL/OAUTHBEARER.
CfnReplicator.KafkaClusterSaslScramAuthenticationPropertyStructDetails for SASL/SCRAM client authentication.
CfnReplicator.LogDeliveryPropertyStructConfiguration for log delivery for the replicator.
CfnReplicator.ReplicationInfoPropertyStructSpecifies configuration for replication between a source and target Kafka cluster.
CfnReplicator.ReplicationStartingPositionPropertyStructSpecifies the position in the topics to start replicating from.
CfnReplicator.ReplicationTopicNameConfigurationPropertyStructConfiguration for specifying replicated topic names will be the same as their corresponding upstream topics or prefixed with source cluster alias.
CfnReplicator.ReplicatorLogDeliveryPropertyStructDetails of the log delivery for the replicator.
CfnReplicator.S3PropertyStructDetails about delivering logs to S3.
CfnReplicator.TopicReplicationPropertyStructDetails about topic replication.
CfnReplicatorPropsStructProperties for defining a CfnReplicator.
CfnServerlessCluster.ClientAuthenticationPropertyStructIncludes all client authentication information.
CfnServerlessCluster.IamPropertyStructDetails for SASL/IAM client authentication.
CfnServerlessCluster.SaslPropertyStructDetails for client authentication using SASL.
CfnServerlessCluster.VpcConfigPropertyStruct
CfnServerlessClusterPropsStructProperties for defining a CfnServerlessCluster.
CfnTopicPropsStructProperties for defining a CfnTopic.
CfnVpcConnectionPropsStructProperties for defining a CfnVpcConnection.