AWS Cloud Control v1.26.0, Mar 12 25

We recommend new projects start with resources from the AWS provider.

AWS Cloud Control v1.26.0 published on Wednesday, Mar 12, 2025 by Pulumi

aws-native.msk.Cluster

Explore with Pulumi AI

We recommend new projects start with resources from the AWS provider.

AWS Cloud Control v1.26.0 published on Wednesday, Mar 12, 2025 by Pulumi

Create Cluster Resource

Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

new Cluster(name: string, args: ClusterArgs, opts?: CustomResourceOptions);

@overload
def Cluster(resource_name: str,
            args: ClusterArgs,
            opts: Optional[ResourceOptions] = None)

@overload
def Cluster(resource_name: str,
            opts: Optional[ResourceOptions] = None,
            broker_node_group_info: Optional[ClusterBrokerNodeGroupInfoArgs] = None,
            number_of_broker_nodes: Optional[int] = None,
            kafka_version: Optional[str] = None,
            configuration_info: Optional[ClusterConfigurationInfoArgs] = None,
            current_version: Optional[str] = None,
            encryption_info: Optional[ClusterEncryptionInfoArgs] = None,
            enhanced_monitoring: Optional[ClusterEnhancedMonitoring] = None,
            cluster_name: Optional[str] = None,
            logging_info: Optional[ClusterLoggingInfoArgs] = None,
            client_authentication: Optional[ClusterClientAuthenticationArgs] = None,
            open_monitoring: Optional[ClusterOpenMonitoringArgs] = None,
            storage_mode: Optional[ClusterStorageMode] = None,
            tags: Optional[Mapping[str, str]] = None)

func NewCluster(ctx *Context, name string, args ClusterArgs, opts ...ResourceOption) (*Cluster, error)

public Cluster(string name, ClusterArgs args, CustomResourceOptions? opts = null)

public Cluster(String name, ClusterArgs args)
public Cluster(String name, ClusterArgs args, CustomResourceOptions options)

type: aws-native:msk:Cluster
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

Parameters

name string: The unique name of the resource.
args ClusterArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

resource_name str: The unique name of the resource.
args ClusterArgs: The arguments to resource properties.
opts ResourceOptions: Bag of options to control resource's behavior.

ctx Context: Context object for the current deployment.
name string: The unique name of the resource.
args ClusterArgs: The arguments to resource properties.
opts ResourceOption: Bag of options to control resource's behavior.

name string: The unique name of the resource.
args ClusterArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

name String: The unique name of the resource.
args ClusterArgs: The arguments to resource properties.
options CustomResourceOptions: Bag of options to control resource's behavior.

Cluster Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

Inputs

In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

The Cluster resource accepts the following input properties:

BrokerNodeGroupInfo Pulumi.AwsNative.Msk.Inputs.ClusterBrokerNodeGroupInfo: Information about the broker nodes in the cluster.
KafkaVersion string: The version of Apache Kafka. You can use Amazon MSK to create clusters that use supported Apache Kafka versions .
NumberOfBrokerNodes int: The number of broker nodes in the cluster.
ClientAuthentication Pulumi.AwsNative.Msk.Inputs.ClusterClientAuthentication: Includes all client authentication related information.
ClusterName string: The name of the cluster.
ConfigurationInfo Pulumi.AwsNative.Msk.Inputs.ClusterConfigurationInfo: Represents the configuration that you want MSK to use for the cluster.
CurrentVersion string: The current version of the MSK cluster
EncryptionInfo Pulumi.AwsNative.Msk.Inputs.ClusterEncryptionInfo: Includes all encryption-related information.
EnhancedMonitoring Pulumi.AwsNative.Msk.ClusterEnhancedMonitoring: Specifies the level of monitoring for the MSK cluster.
LoggingInfo Pulumi.AwsNative.Msk.Inputs.ClusterLoggingInfo: Logging info details for the cluster.
OpenMonitoring Pulumi.AwsNative.Msk.Inputs.ClusterOpenMonitoring: The settings for open monitoring.
StorageMode Pulumi.AwsNative.Msk.ClusterStorageMode: This controls storage mode for supported storage tiers.
Tags Dictionary<string, string>: A key-value pair to associate with a resource.

BrokerNodeGroupInfo ClusterBrokerNodeGroupInfoArgs: Information about the broker nodes in the cluster.
KafkaVersion string: The version of Apache Kafka. You can use Amazon MSK to create clusters that use supported Apache Kafka versions .
NumberOfBrokerNodes int: The number of broker nodes in the cluster.
ClientAuthentication ClusterClientAuthenticationArgs: Includes all client authentication related information.
ClusterName string: The name of the cluster.
ConfigurationInfo ClusterConfigurationInfoArgs: Represents the configuration that you want MSK to use for the cluster.
CurrentVersion string: The current version of the MSK cluster
EncryptionInfo ClusterEncryptionInfoArgs: Includes all encryption-related information.
EnhancedMonitoring ClusterEnhancedMonitoring: Specifies the level of monitoring for the MSK cluster.
LoggingInfo ClusterLoggingInfoArgs: Logging info details for the cluster.
OpenMonitoring ClusterOpenMonitoringArgs: The settings for open monitoring.
StorageMode ClusterStorageMode: This controls storage mode for supported storage tiers.
Tags map[string]string: A key-value pair to associate with a resource.

brokerNodeGroupInfo ClusterBrokerNodeGroupInfo: Information about the broker nodes in the cluster.
kafkaVersion String: The version of Apache Kafka. You can use Amazon MSK to create clusters that use supported Apache Kafka versions .
numberOfBrokerNodes Integer: The number of broker nodes in the cluster.
clientAuthentication ClusterClientAuthentication: Includes all client authentication related information.
clusterName String: The name of the cluster.
configurationInfo ClusterConfigurationInfo: Represents the configuration that you want MSK to use for the cluster.
currentVersion String: The current version of the MSK cluster
encryptionInfo ClusterEncryptionInfo: Includes all encryption-related information.
enhancedMonitoring ClusterEnhancedMonitoring: Specifies the level of monitoring for the MSK cluster.
loggingInfo ClusterLoggingInfo: Logging info details for the cluster.
openMonitoring ClusterOpenMonitoring: The settings for open monitoring.
storageMode ClusterStorageMode: This controls storage mode for supported storage tiers.
tags Map<String,String>: A key-value pair to associate with a resource.

brokerNodeGroupInfo ClusterBrokerNodeGroupInfo: Information about the broker nodes in the cluster.
kafkaVersion string: The version of Apache Kafka. You can use Amazon MSK to create clusters that use supported Apache Kafka versions .
numberOfBrokerNodes number: The number of broker nodes in the cluster.
clientAuthentication ClusterClientAuthentication: Includes all client authentication related information.
clusterName string: The name of the cluster.
configurationInfo ClusterConfigurationInfo: Represents the configuration that you want MSK to use for the cluster.
currentVersion string: The current version of the MSK cluster
encryptionInfo ClusterEncryptionInfo: Includes all encryption-related information.
enhancedMonitoring ClusterEnhancedMonitoring: Specifies the level of monitoring for the MSK cluster.
loggingInfo ClusterLoggingInfo: Logging info details for the cluster.
openMonitoring ClusterOpenMonitoring: The settings for open monitoring.
storageMode ClusterStorageMode: This controls storage mode for supported storage tiers.
tags {[key: string]: string}: A key-value pair to associate with a resource.

broker_node_group_info ClusterBrokerNodeGroupInfoArgs: Information about the broker nodes in the cluster.
kafka_version str: The version of Apache Kafka. You can use Amazon MSK to create clusters that use supported Apache Kafka versions .
number_of_broker_nodes int: The number of broker nodes in the cluster.
client_authentication ClusterClientAuthenticationArgs: Includes all client authentication related information.
cluster_name str: The name of the cluster.
configuration_info ClusterConfigurationInfoArgs: Represents the configuration that you want MSK to use for the cluster.
current_version str: The current version of the MSK cluster
encryption_info ClusterEncryptionInfoArgs: Includes all encryption-related information.
enhanced_monitoring ClusterEnhancedMonitoring: Specifies the level of monitoring for the MSK cluster.
logging_info ClusterLoggingInfoArgs: Logging info details for the cluster.
open_monitoring ClusterOpenMonitoringArgs: The settings for open monitoring.
storage_mode ClusterStorageMode: This controls storage mode for supported storage tiers.
tags Mapping[str, str]: A key-value pair to associate with a resource.

brokerNodeGroupInfo Property Map: Information about the broker nodes in the cluster.
kafkaVersion String: The version of Apache Kafka. You can use Amazon MSK to create clusters that use supported Apache Kafka versions .
numberOfBrokerNodes Number: The number of broker nodes in the cluster.
clientAuthentication Property Map: Includes all client authentication related information.
clusterName String: The name of the cluster.
configurationInfo Property Map: Represents the configuration that you want MSK to use for the cluster.
currentVersion String: The current version of the MSK cluster
encryptionInfo Property Map: Includes all encryption-related information.
enhancedMonitoring "DEFAULT" | "PER_BROKER" | "PER_TOPIC_PER_BROKER" | "PER_TOPIC_PER_PARTITION": Specifies the level of monitoring for the MSK cluster.
loggingInfo Property Map: Logging info details for the cluster.
openMonitoring Property Map: The settings for open monitoring.
storageMode "LOCAL" | "TIERED": This controls storage mode for supported storage tiers.
tags Map<String>: A key-value pair to associate with a resource.

Outputs

All input properties are implicitly available as output properties. Additionally, the Cluster resource produces the following output properties:

Arn string: The Amazon Resource Name (ARN) of the MSK cluster.
Id string: The provider-assigned unique ID for this managed resource.

Arn string: The Amazon Resource Name (ARN) of the MSK cluster.
Id string: The provider-assigned unique ID for this managed resource.

arn String: The Amazon Resource Name (ARN) of the MSK cluster.
id String: The provider-assigned unique ID for this managed resource.

arn string: The Amazon Resource Name (ARN) of the MSK cluster.
id string: The provider-assigned unique ID for this managed resource.

arn str: The Amazon Resource Name (ARN) of the MSK cluster.
id str: The provider-assigned unique ID for this managed resource.

arn String: The Amazon Resource Name (ARN) of the MSK cluster.
id String: The provider-assigned unique ID for this managed resource.

Supporting Types

ClusterBrokerLogs
, ClusterBrokerLogsArgs

CloudWatchLogs Pulumi.AwsNative.Msk.Inputs.ClusterCloudWatchLogs
Firehose Pulumi.AwsNative.Msk.Inputs.ClusterFirehose
S3 Pulumi.AwsNative.Msk.Inputs.ClusterS3

CloudWatchLogs ClusterCloudWatchLogs
Firehose ClusterFirehose
S3 ClusterS3

cloudWatchLogs ClusterCloudWatchLogs
firehose ClusterFirehose
s3 ClusterS3

cloudWatchLogs ClusterCloudWatchLogs
firehose ClusterFirehose
s3 ClusterS3

cloud_watch_logs ClusterCloudWatchLogs
firehose ClusterFirehose
s3 ClusterS3

cloudWatchLogs Property Map
firehose Property Map
s3 Property Map

ClusterBrokerNodeGroupInfo
, ClusterBrokerNodeGroupInfoArgs

ClientSubnets List<string>

The list of subnets to connect to in the client virtual private cloud (VPC). Amazon creates elastic network interfaces (ENIs) inside these subnets. Client applications use ENIs to produce and consume data.

If you use the US West (N. California) Region, specify exactly two subnets. For other Regions where Amazon MSK is available, you can specify either two or three subnets. The subnets that you specify must be in distinct Availability Zones. When you create a cluster, Amazon MSK distributes the broker nodes evenly across the subnets that you specify.

Client subnets can't occupy the Availability Zone with ID use1-az3 .

InstanceType string

The type of Amazon EC2 instances to use for brokers. The following instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge, kafka.m5.4xlarge, kafka.m5.8xlarge, kafka.m5.12xlarge, kafka.m5.16xlarge, kafka.m5.24xlarge, and kafka.t3.small.

BrokerAzDistribution string

This parameter is currently not in use.

ConnectivityInfo Pulumi.AwsNative.Msk.Inputs.ClusterConnectivityInfo

Information about the cluster's connectivity setting.

SecurityGroups List<string>

The security groups to associate with the ENIs in order to specify who can connect to and communicate with the Amazon MSK cluster. If you don't specify a security group, Amazon MSK uses the default security group associated with the VPC. If you specify security groups that were shared with you, you must ensure that you have permissions to them. Specifically, you need the ec2:DescribeSecurityGroups permission.

StorageInfo Pulumi.AwsNative.Msk.Inputs.ClusterStorageInfo

Contains information about storage volumes attached to Amazon MSK broker nodes.

ClientSubnets []string

Client subnets can't occupy the Availability Zone with ID use1-az3 .

InstanceType string

BrokerAzDistribution string

This parameter is currently not in use.

ConnectivityInfo ClusterConnectivityInfo

Information about the cluster's connectivity setting.

SecurityGroups []string

StorageInfo ClusterStorageInfo

Contains information about storage volumes attached to Amazon MSK broker nodes.

clientSubnets List<String>

Client subnets can't occupy the Availability Zone with ID use1-az3 .

instanceType String

brokerAzDistribution String

This parameter is currently not in use.

connectivityInfo ClusterConnectivityInfo

Information about the cluster's connectivity setting.

securityGroups List<String>

storageInfo ClusterStorageInfo

Contains information about storage volumes attached to Amazon MSK broker nodes.

clientSubnets string[]

Client subnets can't occupy the Availability Zone with ID use1-az3 .

instanceType string

brokerAzDistribution string

This parameter is currently not in use.

connectivityInfo ClusterConnectivityInfo

Information about the cluster's connectivity setting.

securityGroups string[]

storageInfo ClusterStorageInfo

Contains information about storage volumes attached to Amazon MSK broker nodes.

client_subnets Sequence[str]

Client subnets can't occupy the Availability Zone with ID use1-az3 .

instance_type str

broker_az_distribution str

This parameter is currently not in use.

connectivity_info ClusterConnectivityInfo

Information about the cluster's connectivity setting.

security_groups Sequence[str]

storage_info ClusterStorageInfo

Contains information about storage volumes attached to Amazon MSK broker nodes.

clientSubnets List<String>

Client subnets can't occupy the Availability Zone with ID use1-az3 .

instanceType String

brokerAzDistribution String

This parameter is currently not in use.

connectivityInfo Property Map

Information about the cluster's connectivity setting.

securityGroups List<String>

storageInfo Property Map

Contains information about storage volumes attached to Amazon MSK broker nodes.

ClusterClientAuthentication
, ClusterClientAuthenticationArgs

Sasl Pulumi.AwsNative.Msk.Inputs.ClusterSasl
Tls Pulumi.AwsNative.Msk.Inputs.ClusterTls
Unauthenticated Pulumi.AwsNative.Msk.Inputs.ClusterUnauthenticated

Sasl ClusterSasl
Tls ClusterTls
Unauthenticated ClusterUnauthenticated

sasl ClusterSasl
tls ClusterTls
unauthenticated ClusterUnauthenticated

sasl ClusterSasl
tls ClusterTls
unauthenticated ClusterUnauthenticated

sasl ClusterSasl
tls ClusterTls
unauthenticated ClusterUnauthenticated

sasl Property Map
tls Property Map
unauthenticated Property Map

ClusterCloudWatchLogs
, ClusterCloudWatchLogsArgs

Enabled bool
LogGroup string

Enabled bool
LogGroup string

enabled Boolean
logGroup String

enabled boolean
logGroup string

enabled bool
log_group str

enabled Boolean
logGroup String

ClusterConfigurationInfo
, ClusterConfigurationInfoArgs

Arn string
Revision int

Arn string
Revision int

arn String
revision Integer

arn string
revision number

arn str
revision int

arn String
revision Number

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

TLS : Indicates that client-broker communication is enabled with TLS only.
TLS_PLAINTEXT : Indicates that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
PLAINTEXT : Indicates that client-broker communication is enabled in plaintext only.

The default value is TLS .

InCluster bool

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

ClientBroker ClusterEncryptionInTransitClientBroker

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

TLS : Indicates that client-broker communication is enabled with TLS only.
TLS_PLAINTEXT : Indicates that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
PLAINTEXT : Indicates that client-broker communication is enabled in plaintext only.

The default value is TLS .

InCluster bool

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

clientBroker ClusterEncryptionInTransitClientBroker

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

TLS : Indicates that client-broker communication is enabled with TLS only.
TLS_PLAINTEXT : Indicates that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
PLAINTEXT : Indicates that client-broker communication is enabled in plaintext only.

The default value is TLS .

inCluster Boolean

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

clientBroker ClusterEncryptionInTransitClientBroker

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

TLS : Indicates that client-broker communication is enabled with TLS only.
TLS_PLAINTEXT : Indicates that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
PLAINTEXT : Indicates that client-broker communication is enabled in plaintext only.

The default value is TLS .

inCluster boolean

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

client_broker ClusterEncryptionInTransitClientBroker

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

TLS : Indicates that client-broker communication is enabled with TLS only.
TLS_PLAINTEXT : Indicates that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
PLAINTEXT : Indicates that client-broker communication is enabled in plaintext only.

The default value is TLS .

in_cluster bool

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

clientBroker "TLS" | "TLS_PLAINTEXT" | "PLAINTEXT"

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

TLS : Indicates that client-broker communication is enabled with TLS only.
TLS_PLAINTEXT : Indicates that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
PLAINTEXT : Indicates that client-broker communication is enabled in plaintext only.

The default value is TLS .

inCluster Boolean

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.