msk¶

This provider is a derived work of the Terraform Provider distributed under MPL 2.0. If you encounter a bug or missing feature, first check the pulumi/pulumi-aws repo; however, if that doesn’t turn up anything, please consult the source terraform-providers/terraform-provider-aws repo.

class pulumi_aws.msk.AwaitableGetClusterResult(arn=None, bootstrap_brokers=None, bootstrap_brokers_tls=None, cluster_name=None, id=None, kafka_version=None, number_of_broker_nodes=None, tags=None, zookeeper_connect_string=None)¶

class pulumi_aws.msk.AwaitableGetConfigurationResult(arn=None, description=None, id=None, kafka_versions=None, latest_revision=None, name=None, server_properties=None)¶

class pulumi_aws.msk.Cluster(resource_name, opts=None, broker_node_group_info=None, client_authentication=None, cluster_name=None, configuration_info=None, encryption_info=None, enhanced_monitoring=None, kafka_version=None, logging_info=None, number_of_broker_nodes=None, open_monitoring=None, tags=None, __props__=None, __name__=None, __opts__=None)¶

Manages AWS Managed Streaming for Kafka cluster

import pulumi
import pulumi_aws as aws

vpc = aws.ec2.Vpc("vpc", cidr_block="192.168.0.0/22")
azs = aws.get_availability_zones(state="available")
subnet_az1 = aws.ec2.Subnet("subnetAz1",
    availability_zone=azs.names[0],
    cidr_block="192.168.0.0/24",
    vpc_id=vpc.id)
subnet_az2 = aws.ec2.Subnet("subnetAz2",
    availability_zone=azs.names[1],
    cidr_block="192.168.1.0/24",
    vpc_id=vpc.id)
subnet_az3 = aws.ec2.Subnet("subnetAz3",
    availability_zone=azs.names[2],
    cidr_block="192.168.2.0/24",
    vpc_id=vpc.id)
sg = aws.ec2.SecurityGroup("sg", vpc_id=vpc.id)
kms = aws.kms.Key("kms", description="example")
test = aws.cloudwatch.LogGroup("test")
bucket = aws.s3.Bucket("bucket", acl="private")
firehose_role = aws.iam.Role("firehoseRole", assume_role_policy="""{
"Version": "2012-10-17",
"Statement": [
  {
    "Action": "sts:AssumeRole",
    "Principal": {
      "Service": "firehose.amazonaws.com"
    },
    "Effect": "Allow",
    "Sid": ""
  }
  ]
}
""")
test_stream = aws.kinesis.FirehoseDeliveryStream("testStream",
    destination="s3",
    s3_configuration={
        "role_arn": firehose_role.arn,
        "bucketArn": bucket.arn,
    },
    tags={
        "LogDeliveryEnabled": "placeholder",
    })
example = aws.msk.Cluster("example",
    cluster_name="example",
    kafka_version="2.1.0",
    number_of_broker_nodes=3,
    broker_node_group_info={
        "instance_type": "kafka.m5.large",
        "ebsVolumeSize": 1000,
        "clientSubnets": [
            subnet_az1.id,
            subnet_az2.id,
            subnet_az3.id,
        ],
        "security_groups": [sg.id],
    },
    encryption_info={
        "encryptionAtRestKmsKeyArn": kms.arn,
    },
    open_monitoring={
        "prometheus": {
            "jmx_exporter": {
                "enabledInBroker": True,
            },
            "node_exporter": {
                "enabledInBroker": True,
            },
        },
    },
    logging_info={
        "broker_logs": {
            "cloudwatch_logs": {
                "enabled": True,
                "log_group": test.name,
            },
            "firehose": {
                "enabled": True,
                "deliveryStream": test_stream.name,
            },
            "s3": {
                "enabled": True,
                "bucket": bucket.id,
                "prefix": "logs/msk-",
            },
        },
    },
    tags={
        "foo": "bar",
    })
pulumi.export("zookeeperConnectString", example.zookeeper_connect_string)
pulumi.export("bootstrapBrokers", example.bootstrap_brokers)
pulumi.export("bootstrapBrokersTls", example.bootstrap_brokers_tls)

Parameters

• resource_name (str) – The name of the resource.

• opts (pulumi.ResourceOptions) – Options for the resource.

• broker_node_group_info (pulumi.Input[dict]) – Configuration block for the broker nodes of the Kafka cluster.

• client_authentication (pulumi.Input[dict]) – Configuration block for specifying a client authentication. See below.

• cluster_name (pulumi.Input[str]) – Name of the MSK cluster.

• configuration_info (pulumi.Input[dict]) – Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.

• encryption_info (pulumi.Input[dict]) – Configuration block for specifying encryption. See below.

• enhanced_monitoring (pulumi.Input[str]) – Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch

• kafka_version (pulumi.Input[str]) – Specify the desired Kafka software version.

• logging_info (pulumi.Input[dict]) – Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.

• number_of_broker_nodes (pulumi.Input[float]) – The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.

• open_monitoring (pulumi.Input[dict]) – Configuration block for JMX and Node monitoring for the MSK cluster. See below.

• tags (pulumi.Input[dict]) – A map of tags to assign to the resource

The broker_node_group_info object supports the following:

• azDistribution (pulumi.Input[str]) - The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT.

• clientSubnets (pulumi.Input[list]) - A list of subnets to connect to in client VPC (documentation).

• ebsVolumeSize (pulumi.Input[float]) - The size in GiB of the EBS volume for the data drive on each broker node.

• instance_type (pulumi.Input[str]) - Specify the instance type to use for the kafka brokers. e.g. kafka.m5.large. (Pricing info)

• security_groups (pulumi.Input[list]) - A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.

The client_authentication object supports the following:

• tls (pulumi.Input[dict]) - Configuration block for specifying TLS client authentication. See below.

  • certificateAuthorityArns (pulumi.Input[list]) - List of ACM Certificate Authority Amazon Resource Names (ARNs).

The configuration_info object supports the following:

• arn (pulumi.Input[str]) - Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

• revision (pulumi.Input[float]) - Revision of the MSK Configuration to use in the cluster.

The encryption_info object supports the following:

• encryptionAtRestKmsKeyArn (pulumi.Input[str]) - You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest. If no key is specified, an AWS managed KMS (‘aws/msk’ managed service) key will be used for encrypting the data at rest.

• encryptionInTransit (pulumi.Input[dict]) - Configuration block to specify encryption in transit. See below.

  • clientBroker (pulumi.Input[str]) - Encryption setting for data in transit between clients and brokers. Valid values: TLS, TLS_PLAINTEXT, and PLAINTEXT. Default value is TLS_PLAINTEXT when encryption_in_transit block defined, but TLS when encryption_in_transit block omitted.

  • inCluster (pulumi.Input[bool]) - Whether data communication among broker nodes is encrypted. Default value: true.

The logging_info object supports the following:

• brokerLogs (pulumi.Input[dict]) - Configuration block for Broker Logs settings for logging info. See below.

  • cloudwatchLogs (pulumi.Input[dict])

    • enabled (pulumi.Input[bool]) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

    • log_group (pulumi.Input[str]) - Name of the Cloudwatch Log Group to deliver logs to.

  • firehose (pulumi.Input[dict])

    • deliveryStream (pulumi.Input[str]) - Name of the Kinesis Data Firehose delivery stream to deliver logs to.

    • enabled (pulumi.Input[bool]) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

  • s3 (pulumi.Input[dict])

    • bucket (pulumi.Input[str]) - Name of the S3 bucket to deliver logs to.

    • enabled (pulumi.Input[bool]) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

    • prefix (pulumi.Input[str]) - Prefix to append to the folder name.

The open_monitoring object supports the following:

• prometheus (pulumi.Input[dict]) - Configuration block for Prometheus settings for open monitoring. See below.

  • jmxExporter (pulumi.Input[dict]) - Configuration block for JMX Exporter. See below.

    • enabledInBroker (pulumi.Input[bool]) - Indicates whether you want to enable or disable the JMX Exporter.

  • nodeExporter (pulumi.Input[dict]) - Configuration block for Node Exporter. See below.

    • enabledInBroker (pulumi.Input[bool]) - Indicates whether you want to enable or disable the JMX Exporter.

arn: pulumi.Output[str] = None¶

Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

bootstrap_brokers: pulumi.Output[str] = None¶

A comma separated list of one or more hostname:port pairs of kafka brokers suitable to boostrap connectivity to the kafka cluster. Only contains value if client_broker encryption in transit is set to PLAINTEXT or TLS_PLAINTEXT.

bootstrap_brokers_tls: pulumi.Output[str] = None¶

A comma separated list of one or more DNS names (or IPs) and TLS port pairs kafka brokers suitable to boostrap connectivity to the kafka cluster. Only contains value if client_broker encryption in transit is set to TLS_PLAINTEXT or TLS.

broker_node_group_info: pulumi.Output[dict] = None¶

Configuration block for the broker nodes of the Kafka cluster.

• azDistribution (str) - The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT.

• clientSubnets (list) - A list of subnets to connect to in client VPC (documentation).

• ebsVolumeSize (float) - The size in GiB of the EBS volume for the data drive on each broker node.

• instance_type (str) - Specify the instance type to use for the kafka brokers. e.g. kafka.m5.large. (Pricing info)

• security_groups (list) - A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.

client_authentication: pulumi.Output[dict] = None¶

Configuration block for specifying a client authentication. See below.

• tls (dict) - Configuration block for specifying TLS client authentication. See below.

  • certificateAuthorityArns (list) - List of ACM Certificate Authority Amazon Resource Names (ARNs).

cluster_name: pulumi.Output[str] = None¶

Name of the MSK cluster.

configuration_info: pulumi.Output[dict] = None¶

Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.

• arn (str) - Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

• revision (float) - Revision of the MSK Configuration to use in the cluster.

current_version: pulumi.Output[str] = None¶

Current version of the MSK Cluster used for updates, e.g. K13V1IB3VIYZZH

• encryption_info.0.encryption_at_rest_kms_key_arn - The ARN of the KMS key used for encryption at rest of the broker data volumes.

encryption_info: pulumi.Output[dict] = None¶

Configuration block for specifying encryption. See below.

• encryptionAtRestKmsKeyArn (str) - You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest. If no key is specified, an AWS managed KMS (‘aws/msk’ managed service) key will be used for encrypting the data at rest.

• encryptionInTransit (dict) - Configuration block to specify encryption in transit. See below.

  • clientBroker (str) - Encryption setting for data in transit between clients and brokers. Valid values: TLS, TLS_PLAINTEXT, and PLAINTEXT. Default value is TLS_PLAINTEXT when encryption_in_transit block defined, but TLS when encryption_in_transit block omitted.

  • inCluster (bool) - Whether data communication among broker nodes is encrypted. Default value: true.

enhanced_monitoring: pulumi.Output[str] = None¶

Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch

kafka_version: pulumi.Output[str] = None¶

Specify the desired Kafka software version.

logging_info: pulumi.Output[dict] = None¶

Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.

• brokerLogs (dict) - Configuration block for Broker Logs settings for logging info. See below.

  • cloudwatchLogs (dict)

    • enabled (bool) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

    • log_group (str) - Name of the Cloudwatch Log Group to deliver logs to.

  • firehose (dict)

    • deliveryStream (str) - Name of the Kinesis Data Firehose delivery stream to deliver logs to.

    • enabled (bool) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

  • s3 (dict)

    • bucket (str) - Name of the S3 bucket to deliver logs to.

    • enabled (bool) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

    • prefix (str) - Prefix to append to the folder name.

number_of_broker_nodes: pulumi.Output[float] = None¶

The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.

open_monitoring: pulumi.Output[dict] = None¶

Configuration block for JMX and Node monitoring for the MSK cluster. See below.

• prometheus (dict) - Configuration block for Prometheus settings for open monitoring. See below.

  • jmxExporter (dict) - Configuration block for JMX Exporter. See below.

    • enabledInBroker (bool) - Indicates whether you want to enable or disable the JMX Exporter.

  • nodeExporter (dict) - Configuration block for Node Exporter. See below.

    • enabledInBroker (bool) - Indicates whether you want to enable or disable the JMX Exporter.

tags: pulumi.Output[dict] = None¶

A map of tags to assign to the resource

zookeeper_connect_string: pulumi.Output[str] = None¶

A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster.

static get(resource_name, id, opts=None, arn=None, bootstrap_brokers=None, bootstrap_brokers_tls=None, broker_node_group_info=None, client_authentication=None, cluster_name=None, configuration_info=None, current_version=None, encryption_info=None, enhanced_monitoring=None, kafka_version=None, logging_info=None, number_of_broker_nodes=None, open_monitoring=None, tags=None, zookeeper_connect_string=None)¶

Get an existing Cluster resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters

• resource_name (str) – The unique name of the resulting resource.

• id (str) – The unique provider ID of the resource to lookup.

• opts (pulumi.ResourceOptions) – Options for the resource.

• arn (pulumi.Input[str]) – Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

• bootstrap_brokers (pulumi.Input[str]) – A comma separated list of one or more hostname:port pairs of kafka brokers suitable to boostrap connectivity to the kafka cluster. Only contains value if client_broker encryption in transit is set to PLAINTEXT or TLS_PLAINTEXT.

• bootstrap_brokers_tls (pulumi.Input[str]) – A comma separated list of one or more DNS names (or IPs) and TLS port pairs kafka brokers suitable to boostrap connectivity to the kafka cluster. Only contains value if client_broker encryption in transit is set to TLS_PLAINTEXT or TLS.

• broker_node_group_info (pulumi.Input[dict]) – Configuration block for the broker nodes of the Kafka cluster.

• client_authentication (pulumi.Input[dict]) – Configuration block for specifying a client authentication. See below.

• cluster_name (pulumi.Input[str]) – Name of the MSK cluster.

• configuration_info (pulumi.Input[dict]) – Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.

• current_version (pulumi.Input[str]) – Current version of the MSK Cluster used for updates, e.g. K13V1IB3VIYZZH

* `encryption_info.0.encryption_at_rest_kms_key_arn` - The ARN of the KMS key used for encryption at rest of the broker data volumes.

Parameters

• encryption_info (pulumi.Input[dict]) – Configuration block for specifying encryption. See below.

• enhanced_monitoring (pulumi.Input[str]) –

  Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch

• kafka_version (pulumi.Input[str]) – Specify the desired Kafka software version.

• logging_info (pulumi.Input[dict]) – Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.

• number_of_broker_nodes (pulumi.Input[float]) – The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.

• open_monitoring (pulumi.Input[dict]) – Configuration block for JMX and Node monitoring for the MSK cluster. See below.

• tags (pulumi.Input[dict]) – A map of tags to assign to the resource

• zookeeper_connect_string (pulumi.Input[str]) – A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster.

The broker_node_group_info object supports the following:

• azDistribution (pulumi.Input[str]) - The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT.

• clientSubnets (pulumi.Input[list]) - A list of subnets to connect to in client VPC (documentation).

• ebsVolumeSize (pulumi.Input[float]) - The size in GiB of the EBS volume for the data drive on each broker node.

• instance_type (pulumi.Input[str]) - Specify the instance type to use for the kafka brokers. e.g. kafka.m5.large. (Pricing info)

• security_groups (pulumi.Input[list]) - A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.

The client_authentication object supports the following:

• tls (pulumi.Input[dict]) - Configuration block for specifying TLS client authentication. See below.

  • certificateAuthorityArns (pulumi.Input[list]) - List of ACM Certificate Authority Amazon Resource Names (ARNs).

The configuration_info object supports the following:

• arn (pulumi.Input[str]) - Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

• revision (pulumi.Input[float]) - Revision of the MSK Configuration to use in the cluster.

The encryption_info object supports the following:

• encryptionAtRestKmsKeyArn (pulumi.Input[str]) - You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest. If no key is specified, an AWS managed KMS (‘aws/msk’ managed service) key will be used for encrypting the data at rest.

• encryptionInTransit (pulumi.Input[dict]) - Configuration block to specify encryption in transit. See below.

  • clientBroker (pulumi.Input[str]) - Encryption setting for data in transit between clients and brokers. Valid values: TLS, TLS_PLAINTEXT, and PLAINTEXT. Default value is TLS_PLAINTEXT when encryption_in_transit block defined, but TLS when encryption_in_transit block omitted.

  • inCluster (pulumi.Input[bool]) - Whether data communication among broker nodes is encrypted. Default value: true.

The logging_info object supports the following:

• brokerLogs (pulumi.Input[dict]) - Configuration block for Broker Logs settings for logging info. See below.

  • cloudwatchLogs (pulumi.Input[dict])

    • enabled (pulumi.Input[bool]) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

    • log_group (pulumi.Input[str]) - Name of the Cloudwatch Log Group to deliver logs to.

  • firehose (pulumi.Input[dict])

    • deliveryStream (pulumi.Input[str]) - Name of the Kinesis Data Firehose delivery stream to deliver logs to.

    • enabled (pulumi.Input[bool]) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

  • s3 (pulumi.Input[dict])

    • bucket (pulumi.Input[str]) - Name of the S3 bucket to deliver logs to.

    • enabled (pulumi.Input[bool]) - Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

    • prefix (pulumi.Input[str]) - Prefix to append to the folder name.

The open_monitoring object supports the following:

• prometheus (pulumi.Input[dict]) - Configuration block for Prometheus settings for open monitoring. See below.

  • jmxExporter (pulumi.Input[dict]) - Configuration block for JMX Exporter. See below.

    • enabledInBroker (pulumi.Input[bool]) - Indicates whether you want to enable or disable the JMX Exporter.

  • nodeExporter (pulumi.Input[dict]) - Configuration block for Node Exporter. See below.

    • enabledInBroker (pulumi.Input[bool]) - Indicates whether you want to enable or disable the JMX Exporter.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aws.msk.Configuration(resource_name, opts=None, description=None, kafka_versions=None, name=None, server_properties=None, __props__=None, __name__=None, __opts__=None)¶

Manages an Amazon Managed Streaming for Kafka configuration. More information can be found on the MSK Developer Guide.

NOTE: The API does not support deleting MSK configurations. Removing this resource will only remove the this provider state for it.

import pulumi
import pulumi_aws as aws

example = aws.msk.Configuration("example",
    kafka_versions=["2.1.0"],
    server_properties="""auto.create.topics.enable = true
delete.topic.enable = true

""")

Parameters

• resource_name (str) – The name of the resource.

• opts (pulumi.ResourceOptions) – Options for the resource.

• description (pulumi.Input[str]) – Description of the configuration.

• kafka_versions (pulumi.Input[list]) – List of Apache Kafka versions which can use this configuration.

• name (pulumi.Input[str]) – Name of the configuration.

• server_properties (pulumi.Input[str]) –

  Contents of the server.properties file. Supported properties are documented in the MSK Developer Guide.

arn: pulumi.Output[str] = None¶

Amazon Resource Name (ARN) of the configuration.

description: pulumi.Output[str] = None¶

Description of the configuration.

kafka_versions: pulumi.Output[list] = None¶

List of Apache Kafka versions which can use this configuration.

latest_revision: pulumi.Output[float] = None¶

Latest revision of the configuration.

name: pulumi.Output[str] = None¶

Name of the configuration.

server_properties: pulumi.Output[str] = None¶

Contents of the server.properties file. Supported properties are documented in the MSK Developer Guide.

static get(resource_name, id, opts=None, arn=None, description=None, kafka_versions=None, latest_revision=None, name=None, server_properties=None)¶

Get an existing Configuration resource’s state with the given name, id, and optional extra properties used to qualify the lookup.

Parameters

• resource_name (str) – The unique name of the resulting resource.

• id (str) – The unique provider ID of the resource to lookup.

• opts (pulumi.ResourceOptions) – Options for the resource.

• arn (pulumi.Input[str]) – Amazon Resource Name (ARN) of the configuration.

• description (pulumi.Input[str]) – Description of the configuration.

• kafka_versions (pulumi.Input[list]) – List of Apache Kafka versions which can use this configuration.

• latest_revision (pulumi.Input[float]) – Latest revision of the configuration.

• name (pulumi.Input[str]) – Name of the configuration.

• server_properties (pulumi.Input[str]) –

  Contents of the server.properties file. Supported properties are documented in the MSK Developer Guide.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters

prop (str) – A property name.

Returns

A potentially transformed property name.

Return type

str

class pulumi_aws.msk.GetClusterResult(arn=None, bootstrap_brokers=None, bootstrap_brokers_tls=None, cluster_name=None, id=None, kafka_version=None, number_of_broker_nodes=None, tags=None, zookeeper_connect_string=None)¶

A collection of values returned by getCluster.

arn = None¶

Amazon Resource Name (ARN) of the MSK cluster.

bootstrap_brokers = None¶

A comma separated list of one or more hostname:port pairs of Kafka brokers suitable to boostrap connectivity to the Kafka cluster.

bootstrap_brokers_tls = None¶

A comma separated list of one or more DNS names (or IPs) and TLS port pairs kafka brokers suitable to boostrap connectivity to the kafka cluster.

id = None¶

The provider-assigned unique ID for this managed resource.

kafka_version = None¶

Apache Kafka version.

number_of_broker_nodes = None¶

Number of broker nodes in the cluster.

tags = None¶

Map of key-value pairs assigned to the cluster.

zookeeper_connect_string = None¶

A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster.

class pulumi_aws.msk.GetConfigurationResult(arn=None, description=None, id=None, kafka_versions=None, latest_revision=None, name=None, server_properties=None)¶

A collection of values returned by getConfiguration.

arn = None¶

Amazon Resource Name (ARN) of the configuration.

description = None¶

Description of the configuration.

id = None¶

The provider-assigned unique ID for this managed resource.

kafka_versions = None¶

List of Apache Kafka versions which can use this configuration.

latest_revision = None¶

Latest revision of the configuration.

server_properties = None¶

Contents of the server.properties file.

pulumi_aws.msk.get_cluster(cluster_name=None, tags=None, opts=None)¶

Get information on an Amazon MSK Cluster.

import pulumi
import pulumi_aws as aws

example = aws.msk.get_cluster(cluster_name="example")

Parameters

• cluster_name (str) – Name of the cluster.

• tags (dict) – Map of key-value pairs assigned to the cluster.

pulumi_aws.msk.get_configuration(name=None, opts=None)¶

Get information on an Amazon MSK Configuration.

import pulumi
import pulumi_aws as aws

example = aws.msk.get_configuration(name="example")

Parameters

name (str) – Name of the configuration.