Docs Packages
  1. Packages
  2. AWS Classic
  3. API Docs
  4. mskconnect
  5. Connector

Try AWS Native preview for resources not in the classic version.

AWS Classic v6.42.0 published on Wednesday, Jun 26, 2024 by Pulumi
pulumi/pulumi-aws

aws.mskconnect.Connector

Explore with Pulumi AI

aws logo

Try AWS Native preview for resources not in the classic version.

AWS Classic v6.42.0 published on Wednesday, Jun 26, 2024 by Pulumi
pulumi/pulumi-aws

    Provides an Amazon MSK Connect Connector resource.

    Example Usage

    Basic configuration

    import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const example = new aws.mskconnect.Connector("example", {
    name: "example",
    kafkaconnectVersion: "2.7.1",
    capacity: {
        autoscaling: {
            mcuCount: 1,
            minWorkerCount: 1,
            maxWorkerCount: 2,
            scaleInPolicy: {
                cpuUtilizationPercentage: 20,
            },
            scaleOutPolicy: {
                cpuUtilizationPercentage: 80,
            },
        },
    },
    connectorConfiguration: {
        "connector.class": "com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector",
        "tasks.max": "1",
        topics: "example",
    },
    kafkaCluster: {
        apacheKafkaCluster: {
            bootstrapServers: exampleAwsMskCluster.bootstrapBrokersTls,
            vpc: {
                securityGroups: [exampleAwsSecurityGroup.id],
                subnets: [
                    example1.id,
                    example2.id,
                    example3.id,
                ],
            },
        },
    },
    kafkaClusterClientAuthentication: {
        authenticationType: "NONE",
    },
    kafkaClusterEncryptionInTransit: {
        encryptionType: "TLS",
    },
    plugins: [{
        customPlugin: {
            arn: exampleAwsMskconnectCustomPlugin.arn,
            revision: exampleAwsMskconnectCustomPlugin.latestRevision,
        },
    }],
    serviceExecutionRoleArn: exampleAwsIamRole.arn,
});

    import pulumi
import pulumi_aws as aws

example = aws.mskconnect.Connector("example",
    name="example",
    kafkaconnect_version="2.7.1",
    capacity={
        "autoscaling": {
            "mcuCount": 1,
            "minWorkerCount": 1,
            "maxWorkerCount": 2,
            "scaleInPolicy": {
                "cpuUtilizationPercentage": 20,
            },
            "scaleOutPolicy": {
                "cpuUtilizationPercentage": 80,
            },
        },
    },
    connector_configuration={
        "connector.class": "com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector",
        "tasks.max": "1",
        "topics": "example",
    },
    kafka_cluster={
        "apacheKafkaCluster": {
            "bootstrapServers": example_aws_msk_cluster["bootstrapBrokersTls"],
            "vpc": {
                "securityGroups": [example_aws_security_group["id"]],
                "subnets": [
                    example1["id"],
                    example2["id"],
                    example3["id"],
                ],
            },
        },
    },
    kafka_cluster_client_authentication={
        "authenticationType": "NONE",
    },
    kafka_cluster_encryption_in_transit={
        "encryptionType": "TLS",
    },
    plugins=[{
        "customPlugin": {
            "arn": example_aws_mskconnect_custom_plugin["arn"],
            "revision": example_aws_mskconnect_custom_plugin["latestRevision"],
        },
    }],
    service_execution_role_arn=example_aws_iam_role["arn"])

    package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.NewConnector(ctx, "example", &mskconnect.ConnectorArgs{
			Name:                pulumi.String("example"),
			KafkaconnectVersion: pulumi.String("2.7.1"),
			Capacity: &mskconnect.ConnectorCapacityArgs{
				Autoscaling: &mskconnect.ConnectorCapacityAutoscalingArgs{
					McuCount:       pulumi.Int(1),
					MinWorkerCount: pulumi.Int(1),
					MaxWorkerCount: pulumi.Int(2),
					ScaleInPolicy: &mskconnect.ConnectorCapacityAutoscalingScaleInPolicyArgs{
						CpuUtilizationPercentage: pulumi.Int(20),
					},
					ScaleOutPolicy: &mskconnect.ConnectorCapacityAutoscalingScaleOutPolicyArgs{
						CpuUtilizationPercentage: pulumi.Int(80),
					},
				},
			},
			ConnectorConfiguration: pulumi.StringMap{
				"connector.class": pulumi.String("com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector"),
				"tasks.max":       pulumi.String("1"),
				"topics":          pulumi.String("example"),
			},
			KafkaCluster: &mskconnect.ConnectorKafkaClusterArgs{
				ApacheKafkaCluster: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterArgs{
					BootstrapServers: pulumi.Any(exampleAwsMskCluster.BootstrapBrokersTls),
					Vpc: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterVpcArgs{
						SecurityGroups: pulumi.StringArray{
							exampleAwsSecurityGroup.Id,
						},
						Subnets: pulumi.StringArray{
							example1.Id,
							example2.Id,
							example3.Id,
						},
					},
				},
			},
			KafkaClusterClientAuthentication: &mskconnect.ConnectorKafkaClusterClientAuthenticationArgs{
				AuthenticationType: pulumi.String("NONE"),
			},
			KafkaClusterEncryptionInTransit: &mskconnect.ConnectorKafkaClusterEncryptionInTransitArgs{
				EncryptionType: pulumi.String("TLS"),
			},
			Plugins: mskconnect.ConnectorPluginArray{
				&mskconnect.ConnectorPluginArgs{
					CustomPlugin: &mskconnect.ConnectorPluginCustomPluginArgs{
						Arn:      pulumi.Any(exampleAwsMskconnectCustomPlugin.Arn),
						Revision: pulumi.Any(exampleAwsMskconnectCustomPlugin.LatestRevision),
					},
				},
			},
			ServiceExecutionRoleArn: pulumi.Any(exampleAwsIamRole.Arn),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var example = new Aws.MskConnect.Connector("example", new()
    {
        Name = "example",
        KafkaconnectVersion = "2.7.1",
        Capacity = new Aws.MskConnect.Inputs.ConnectorCapacityArgs
        {
            Autoscaling = new Aws.MskConnect.Inputs.ConnectorCapacityAutoscalingArgs
            {
                McuCount = 1,
                MinWorkerCount = 1,
                MaxWorkerCount = 2,
                ScaleInPolicy = new Aws.MskConnect.Inputs.ConnectorCapacityAutoscalingScaleInPolicyArgs
                {
                    CpuUtilizationPercentage = 20,
                },
                ScaleOutPolicy = new Aws.MskConnect.Inputs.ConnectorCapacityAutoscalingScaleOutPolicyArgs
                {
                    CpuUtilizationPercentage = 80,
                },
            },
        },
        ConnectorConfiguration = 
        {
            { "connector.class", "com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector" },
            { "tasks.max", "1" },
            { "topics", "example" },
        },
        KafkaCluster = new Aws.MskConnect.Inputs.ConnectorKafkaClusterArgs
        {
            ApacheKafkaCluster = new Aws.MskConnect.Inputs.ConnectorKafkaClusterApacheKafkaClusterArgs
            {
                BootstrapServers = exampleAwsMskCluster.BootstrapBrokersTls,
                Vpc = new Aws.MskConnect.Inputs.ConnectorKafkaClusterApacheKafkaClusterVpcArgs
                {
                    SecurityGroups = new[]
                    {
                        exampleAwsSecurityGroup.Id,
                    },
                    Subnets = new[]
                    {
                        example1.Id,
                        example2.Id,
                        example3.Id,
                    },
                },
            },
        },
        KafkaClusterClientAuthentication = new Aws.MskConnect.Inputs.ConnectorKafkaClusterClientAuthenticationArgs
        {
            AuthenticationType = "NONE",
        },
        KafkaClusterEncryptionInTransit = new Aws.MskConnect.Inputs.ConnectorKafkaClusterEncryptionInTransitArgs
        {
            EncryptionType = "TLS",
        },
        Plugins = new[]
        {
            new Aws.MskConnect.Inputs.ConnectorPluginArgs
            {
                CustomPlugin = new Aws.MskConnect.Inputs.ConnectorPluginCustomPluginArgs
                {
                    Arn = exampleAwsMskconnectCustomPlugin.Arn,
                    Revision = exampleAwsMskconnectCustomPlugin.LatestRevision,
                },
            },
        },
        ServiceExecutionRoleArn = exampleAwsIamRole.Arn,
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.mskconnect.Connector;
import com.pulumi.aws.mskconnect.ConnectorArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityAutoscalingArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityAutoscalingScaleInPolicyArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityAutoscalingScaleOutPolicyArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterApacheKafkaClusterArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterApacheKafkaClusterVpcArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterClientAuthenticationArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterEncryptionInTransitArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorPluginArgs;
import com.pulumi.aws.mskconnect.inputs.ConnectorPluginCustomPluginArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var example = new Connector("example", ConnectorArgs.builder()
            .name("example")
            .kafkaconnectVersion("2.7.1")
            .capacity(ConnectorCapacityArgs.builder()
                .autoscaling(ConnectorCapacityAutoscalingArgs.builder()
                    .mcuCount(1)
                    .minWorkerCount(1)
                    .maxWorkerCount(2)
                    .scaleInPolicy(ConnectorCapacityAutoscalingScaleInPolicyArgs.builder()
                        .cpuUtilizationPercentage(20)
                        .build())
                    .scaleOutPolicy(ConnectorCapacityAutoscalingScaleOutPolicyArgs.builder()
                        .cpuUtilizationPercentage(80)
                        .build())
                    .build())
                .build())
            .connectorConfiguration(Map.ofEntries(
                Map.entry("connector.class", "com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector"),
                Map.entry("tasks.max", "1"),
                Map.entry("topics", "example")
            ))
            .kafkaCluster(ConnectorKafkaClusterArgs.builder()
                .apacheKafkaCluster(ConnectorKafkaClusterApacheKafkaClusterArgs.builder()
                    .bootstrapServers(exampleAwsMskCluster.bootstrapBrokersTls())
                    .vpc(ConnectorKafkaClusterApacheKafkaClusterVpcArgs.builder()
                        .securityGroups(exampleAwsSecurityGroup.id())
                        .subnets(                        
                            example1.id(),
                            example2.id(),
                            example3.id())
                        .build())
                    .build())
                .build())
            .kafkaClusterClientAuthentication(ConnectorKafkaClusterClientAuthenticationArgs.builder()
                .authenticationType("NONE")
                .build())
            .kafkaClusterEncryptionInTransit(ConnectorKafkaClusterEncryptionInTransitArgs.builder()
                .encryptionType("TLS")
                .build())
            .plugins(ConnectorPluginArgs.builder()
                .customPlugin(ConnectorPluginCustomPluginArgs.builder()
                    .arn(exampleAwsMskconnectCustomPlugin.arn())
                    .revision(exampleAwsMskconnectCustomPlugin.latestRevision())
                    .build())
                .build())
            .serviceExecutionRoleArn(exampleAwsIamRole.arn())
            .build());

    }
}

    resources:
  example:
    type: aws:mskconnect:Connector
    properties:
      name: example
      kafkaconnectVersion: 2.7.1
      capacity:
        autoscaling:
          mcuCount: 1
          minWorkerCount: 1
          maxWorkerCount: 2
          scaleInPolicy:
            cpuUtilizationPercentage: 20
          scaleOutPolicy:
            cpuUtilizationPercentage: 80
      connectorConfiguration:
        connector.class: com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector
        tasks.max: '1'
        topics: example
      kafkaCluster:
        apacheKafkaCluster:
          bootstrapServers: ${exampleAwsMskCluster.bootstrapBrokersTls}
          vpc:
            securityGroups:
              - ${exampleAwsSecurityGroup.id}
            subnets:
              - ${example1.id}
              - ${example2.id}
              - ${example3.id}
      kafkaClusterClientAuthentication:
        authenticationType: NONE
      kafkaClusterEncryptionInTransit:
        encryptionType: TLS
      plugins:
        - customPlugin:
            arn: ${exampleAwsMskconnectCustomPlugin.arn}
            revision: ${exampleAwsMskconnectCustomPlugin.latestRevision}
      serviceExecutionRoleArn: ${exampleAwsIamRole.arn}

    Create Connector Resource

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

    Constructor syntax

    new Connector(name: string, args: ConnectorArgs, opts?: CustomResourceOptions);
    @overload
def Connector(resource_name: str,
              args: ConnectorArgs,
              opts: Optional[ResourceOptions] = None)

@overload
def Connector(resource_name: str,
              opts: Optional[ResourceOptions] = None,
              capacity: Optional[ConnectorCapacityArgs] = None,
              connector_configuration: Optional[Mapping[str, str]] = None,
              kafka_cluster: Optional[ConnectorKafkaClusterArgs] = None,
              kafka_cluster_client_authentication: Optional[ConnectorKafkaClusterClientAuthenticationArgs] = None,
              kafka_cluster_encryption_in_transit: Optional[ConnectorKafkaClusterEncryptionInTransitArgs] = None,
              kafkaconnect_version: Optional[str] = None,
              plugins: Optional[Sequence[ConnectorPluginArgs]] = None,
              service_execution_role_arn: Optional[str] = None,
              description: Optional[str] = None,
              log_delivery: Optional[ConnectorLogDeliveryArgs] = None,
              name: Optional[str] = None,
              worker_configuration: Optional[ConnectorWorkerConfigurationArgs] = None)
    func NewConnector(ctx *Context, name string, args ConnectorArgs, opts ...ResourceOption) (*Connector, error)
    public Connector(string name, ConnectorArgs args, CustomResourceOptions? opts = null)
    public Connector(String name, ConnectorArgs args)
public Connector(String name, ConnectorArgs args, CustomResourceOptions options)

    type: aws:mskconnect:Connector
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 ConnectorArgs
    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 ConnectorArgs
    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 ConnectorArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args ConnectorArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args ConnectorArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var connectorResource = new Aws.MskConnect.Connector("connectorResource", new()
{
    Capacity = new Aws.MskConnect.Inputs.ConnectorCapacityArgs
    {
        Autoscaling = new Aws.MskConnect.Inputs.ConnectorCapacityAutoscalingArgs
        {
            MaxWorkerCount = 0,
            MinWorkerCount = 0,
            McuCount = 0,
            ScaleInPolicy = new Aws.MskConnect.Inputs.ConnectorCapacityAutoscalingScaleInPolicyArgs
            {
                CpuUtilizationPercentage = 0,
            },
            ScaleOutPolicy = new Aws.MskConnect.Inputs.ConnectorCapacityAutoscalingScaleOutPolicyArgs
            {
                CpuUtilizationPercentage = 0,
            },
        },
        ProvisionedCapacity = new Aws.MskConnect.Inputs.ConnectorCapacityProvisionedCapacityArgs
        {
            WorkerCount = 0,
            McuCount = 0,
        },
    },
    ConnectorConfiguration = 
    {
        { "string", "string" },
    },
    KafkaCluster = new Aws.MskConnect.Inputs.ConnectorKafkaClusterArgs
    {
        ApacheKafkaCluster = new Aws.MskConnect.Inputs.ConnectorKafkaClusterApacheKafkaClusterArgs
        {
            BootstrapServers = "string",
            Vpc = new Aws.MskConnect.Inputs.ConnectorKafkaClusterApacheKafkaClusterVpcArgs
            {
                SecurityGroups = new[]
                {
                    "string",
                },
                Subnets = new[]
                {
                    "string",
                },
            },
        },
    },
    KafkaClusterClientAuthentication = new Aws.MskConnect.Inputs.ConnectorKafkaClusterClientAuthenticationArgs
    {
        AuthenticationType = "string",
    },
    KafkaClusterEncryptionInTransit = new Aws.MskConnect.Inputs.ConnectorKafkaClusterEncryptionInTransitArgs
    {
        EncryptionType = "string",
    },
    KafkaconnectVersion = "string",
    Plugins = new[]
    {
        new Aws.MskConnect.Inputs.ConnectorPluginArgs
        {
            CustomPlugin = new Aws.MskConnect.Inputs.ConnectorPluginCustomPluginArgs
            {
                Arn = "string",
                Revision = 0,
            },
        },
    },
    ServiceExecutionRoleArn = "string",
    Description = "string",
    LogDelivery = new Aws.MskConnect.Inputs.ConnectorLogDeliveryArgs
    {
        WorkerLogDelivery = new Aws.MskConnect.Inputs.ConnectorLogDeliveryWorkerLogDeliveryArgs
        {
            CloudwatchLogs = new Aws.MskConnect.Inputs.ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs
            {
                Enabled = false,
                LogGroup = "string",
            },
            Firehose = new Aws.MskConnect.Inputs.ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs
            {
                Enabled = false,
                DeliveryStream = "string",
            },
            S3 = new Aws.MskConnect.Inputs.ConnectorLogDeliveryWorkerLogDeliveryS3Args
            {
                Enabled = false,
                Bucket = "string",
                Prefix = "string",
            },
        },
    },
    Name = "string",
    WorkerConfiguration = new Aws.MskConnect.Inputs.ConnectorWorkerConfigurationArgs
    {
        Arn = "string",
        Revision = 0,
    },
});

    example, err := mskconnect.NewConnector(ctx, "connectorResource", &mskconnect.ConnectorArgs{
	Capacity: &mskconnect.ConnectorCapacityArgs{
		Autoscaling: &mskconnect.ConnectorCapacityAutoscalingArgs{
			MaxWorkerCount: pulumi.Int(0),
			MinWorkerCount: pulumi.Int(0),
			McuCount:       pulumi.Int(0),
			ScaleInPolicy: &mskconnect.ConnectorCapacityAutoscalingScaleInPolicyArgs{
				CpuUtilizationPercentage: pulumi.Int(0),
			},
			ScaleOutPolicy: &mskconnect.ConnectorCapacityAutoscalingScaleOutPolicyArgs{
				CpuUtilizationPercentage: pulumi.Int(0),
			},
		},
		ProvisionedCapacity: &mskconnect.ConnectorCapacityProvisionedCapacityArgs{
			WorkerCount: pulumi.Int(0),
			McuCount:    pulumi.Int(0),
		},
	},
	ConnectorConfiguration: pulumi.StringMap{
		"string": pulumi.String("string"),
	},
	KafkaCluster: &mskconnect.ConnectorKafkaClusterArgs{
		ApacheKafkaCluster: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterArgs{
			BootstrapServers: pulumi.String("string"),
			Vpc: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterVpcArgs{
				SecurityGroups: pulumi.StringArray{
					pulumi.String("string"),
				},
				Subnets: pulumi.StringArray{
					pulumi.String("string"),
				},
			},
		},
	},
	KafkaClusterClientAuthentication: &mskconnect.ConnectorKafkaClusterClientAuthenticationArgs{
		AuthenticationType: pulumi.String("string"),
	},
	KafkaClusterEncryptionInTransit: &mskconnect.ConnectorKafkaClusterEncryptionInTransitArgs{
		EncryptionType: pulumi.String("string"),
	},
	KafkaconnectVersion: pulumi.String("string"),
	Plugins: mskconnect.ConnectorPluginArray{
		&mskconnect.ConnectorPluginArgs{
			CustomPlugin: &mskconnect.ConnectorPluginCustomPluginArgs{
				Arn:      pulumi.String("string"),
				Revision: pulumi.Int(0),
			},
		},
	},
	ServiceExecutionRoleArn: pulumi.String("string"),
	Description:             pulumi.String("string"),
	LogDelivery: &mskconnect.ConnectorLogDeliveryArgs{
		WorkerLogDelivery: &mskconnect.ConnectorLogDeliveryWorkerLogDeliveryArgs{
			CloudwatchLogs: &mskconnect.ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs{
				Enabled:  pulumi.Bool(false),
				LogGroup: pulumi.String("string"),
			},
			Firehose: &mskconnect.ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs{
				Enabled:        pulumi.Bool(false),
				DeliveryStream: pulumi.String("string"),
			},
			S3: &mskconnect.ConnectorLogDeliveryWorkerLogDeliveryS3Args{
				Enabled: pulumi.Bool(false),
				Bucket:  pulumi.String("string"),
				Prefix:  pulumi.String("string"),
			},
		},
	},
	Name: pulumi.String("string"),
	WorkerConfiguration: &mskconnect.ConnectorWorkerConfigurationArgs{
		Arn:      pulumi.String("string"),
		Revision: pulumi.Int(0),
	},
})

    var connectorResource = new Connector("connectorResource", ConnectorArgs.builder()
    .capacity(ConnectorCapacityArgs.builder()
        .autoscaling(ConnectorCapacityAutoscalingArgs.builder()
            .maxWorkerCount(0)
            .minWorkerCount(0)
            .mcuCount(0)
            .scaleInPolicy(ConnectorCapacityAutoscalingScaleInPolicyArgs.builder()
                .cpuUtilizationPercentage(0)
                .build())
            .scaleOutPolicy(ConnectorCapacityAutoscalingScaleOutPolicyArgs.builder()
                .cpuUtilizationPercentage(0)
                .build())
            .build())
        .provisionedCapacity(ConnectorCapacityProvisionedCapacityArgs.builder()
            .workerCount(0)
            .mcuCount(0)
            .build())
        .build())
    .connectorConfiguration(Map.of("string", "string"))
    .kafkaCluster(ConnectorKafkaClusterArgs.builder()
        .apacheKafkaCluster(ConnectorKafkaClusterApacheKafkaClusterArgs.builder()
            .bootstrapServers("string")
            .vpc(ConnectorKafkaClusterApacheKafkaClusterVpcArgs.builder()
                .securityGroups("string")
                .subnets("string")
                .build())
            .build())
        .build())
    .kafkaClusterClientAuthentication(ConnectorKafkaClusterClientAuthenticationArgs.builder()
        .authenticationType("string")
        .build())
    .kafkaClusterEncryptionInTransit(ConnectorKafkaClusterEncryptionInTransitArgs.builder()
        .encryptionType("string")
        .build())
    .kafkaconnectVersion("string")
    .plugins(ConnectorPluginArgs.builder()
        .customPlugin(ConnectorPluginCustomPluginArgs.builder()
            .arn("string")
            .revision(0)
            .build())
        .build())
    .serviceExecutionRoleArn("string")
    .description("string")
    .logDelivery(ConnectorLogDeliveryArgs.builder()
        .workerLogDelivery(ConnectorLogDeliveryWorkerLogDeliveryArgs.builder()
            .cloudwatchLogs(ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs.builder()
                .enabled(false)
                .logGroup("string")
                .build())
            .firehose(ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs.builder()
                .enabled(false)
                .deliveryStream("string")
                .build())
            .s3(ConnectorLogDeliveryWorkerLogDeliveryS3Args.builder()
                .enabled(false)
                .bucket("string")
                .prefix("string")
                .build())
            .build())
        .build())
    .name("string")
    .workerConfiguration(ConnectorWorkerConfigurationArgs.builder()
        .arn("string")
        .revision(0)
        .build())
    .build());

    connector_resource = aws.mskconnect.Connector("connectorResource",
    capacity={
        "autoscaling": {
            "maxWorkerCount": 0,
            "minWorkerCount": 0,
            "mcuCount": 0,
            "scaleInPolicy": {
                "cpuUtilizationPercentage": 0,
            },
            "scaleOutPolicy": {
                "cpuUtilizationPercentage": 0,
            },
        },
        "provisionedCapacity": {
            "workerCount": 0,
            "mcuCount": 0,
        },
    },
    connector_configuration={
        "string": "string",
    },
    kafka_cluster={
        "apacheKafkaCluster": {
            "bootstrapServers": "string",
            "vpc": {
                "securityGroups": ["string"],
                "subnets": ["string"],
            },
        },
    },
    kafka_cluster_client_authentication={
        "authenticationType": "string",
    },
    kafka_cluster_encryption_in_transit={
        "encryptionType": "string",
    },
    kafkaconnect_version="string",
    plugins=[{
        "customPlugin": {
            "arn": "string",
            "revision": 0,
        },
    }],
    service_execution_role_arn="string",
    description="string",
    log_delivery={
        "workerLogDelivery": {
            "cloudwatchLogs": {
                "enabled": False,
                "logGroup": "string",
            },
            "firehose": {
                "enabled": False,
                "deliveryStream": "string",
            },
            "s3": {
                "enabled": False,
                "bucket": "string",
                "prefix": "string",
            },
        },
    },
    name="string",
    worker_configuration={
        "arn": "string",
        "revision": 0,
    })

    const connectorResource = new aws.mskconnect.Connector("connectorResource", {
    capacity: {
        autoscaling: {
            maxWorkerCount: 0,
            minWorkerCount: 0,
            mcuCount: 0,
            scaleInPolicy: {
                cpuUtilizationPercentage: 0,
            },
            scaleOutPolicy: {
                cpuUtilizationPercentage: 0,
            },
        },
        provisionedCapacity: {
            workerCount: 0,
            mcuCount: 0,
        },
    },
    connectorConfiguration: {
        string: "string",
    },
    kafkaCluster: {
        apacheKafkaCluster: {
            bootstrapServers: "string",
            vpc: {
                securityGroups: ["string"],
                subnets: ["string"],
            },
        },
    },
    kafkaClusterClientAuthentication: {
        authenticationType: "string",
    },
    kafkaClusterEncryptionInTransit: {
        encryptionType: "string",
    },
    kafkaconnectVersion: "string",
    plugins: [{
        customPlugin: {
            arn: "string",
            revision: 0,
        },
    }],
    serviceExecutionRoleArn: "string",
    description: "string",
    logDelivery: {
        workerLogDelivery: {
            cloudwatchLogs: {
                enabled: false,
                logGroup: "string",
            },
            firehose: {
                enabled: false,
                deliveryStream: "string",
            },
            s3: {
                enabled: false,
                bucket: "string",
                prefix: "string",
            },
        },
    },
    name: "string",
    workerConfiguration: {
        arn: "string",
        revision: 0,
    },
});

    type: aws:mskconnect:Connector
properties:
    capacity:
        autoscaling:
            maxWorkerCount: 0
            mcuCount: 0
            minWorkerCount: 0
            scaleInPolicy:
                cpuUtilizationPercentage: 0
            scaleOutPolicy:
                cpuUtilizationPercentage: 0
        provisionedCapacity:
            mcuCount: 0
            workerCount: 0
    connectorConfiguration:
        string: string
    description: string
    kafkaCluster:
        apacheKafkaCluster:
            bootstrapServers: string
            vpc:
                securityGroups:
                    - string
                subnets:
                    - string
    kafkaClusterClientAuthentication:
        authenticationType: string
    kafkaClusterEncryptionInTransit:
        encryptionType: string
    kafkaconnectVersion: string
    logDelivery:
        workerLogDelivery:
            cloudwatchLogs:
                enabled: false
                logGroup: string
            firehose:
                deliveryStream: string
                enabled: false
            s3:
                bucket: string
                enabled: false
                prefix: string
    name: string
    plugins:
        - customPlugin:
            arn: string
            revision: 0
    serviceExecutionRoleArn: string
    workerConfiguration:
        arn: string
        revision: 0

    Connector Resource Properties

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

    Inputs

    The Connector resource accepts the following input properties:

    Capacity ConnectorCapacity
    Information about the capacity allocated to the connector. See below.
    ConnectorConfiguration Dictionary<string, string>
    A map of keys to values that represent the configuration for the connector.
    KafkaCluster ConnectorKafkaCluster
    Specifies which Apache Kafka cluster to connect to. See below.
    KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication
    Details of the client authentication used by the Apache Kafka cluster. See below.
    KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit
    Details of encryption in transit to the Apache Kafka cluster. See below.
    KafkaconnectVersion string
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    Plugins List<ConnectorPlugin>
    Specifies which plugins to use for the connector. See below.
    ServiceExecutionRoleArn string
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    Description string
    A summary description of the connector.
    LogDelivery ConnectorLogDelivery
    Details about log delivery. See below.
    Name string
    The name of the connector.
    WorkerConfiguration ConnectorWorkerConfiguration
    Specifies which worker configuration to use with the connector. See below.
    Capacity ConnectorCapacityArgs
    Information about the capacity allocated to the connector. See below.
    ConnectorConfiguration map[string]string
    A map of keys to values that represent the configuration for the connector.
    KafkaCluster ConnectorKafkaClusterArgs
    Specifies which Apache Kafka cluster to connect to. See below.
    KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationArgs
    Details of the client authentication used by the Apache Kafka cluster. See below.
    KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitArgs
    Details of encryption in transit to the Apache Kafka cluster. See below.
    KafkaconnectVersion string
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    Plugins []ConnectorPluginArgs
    Specifies which plugins to use for the connector. See below.
    ServiceExecutionRoleArn string
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    Description string
    A summary description of the connector.
    LogDelivery ConnectorLogDeliveryArgs
    Details about log delivery. See below.
    Name string
    The name of the connector.
    WorkerConfiguration ConnectorWorkerConfigurationArgs
    Specifies which worker configuration to use with the connector. See below.
    capacity ConnectorCapacity
    Information about the capacity allocated to the connector. See below.
    connectorConfiguration Map<String,String>
    A map of keys to values that represent the configuration for the connector.
    kafkaCluster ConnectorKafkaCluster
    Specifies which Apache Kafka cluster to connect to. See below.
    kafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnectVersion String
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    plugins List<ConnectorPlugin>
    Specifies which plugins to use for the connector. See below.
    serviceExecutionRoleArn String
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    description String
    A summary description of the connector.
    logDelivery ConnectorLogDelivery
    Details about log delivery. See below.
    name String
    The name of the connector.
    workerConfiguration ConnectorWorkerConfiguration
    Specifies which worker configuration to use with the connector. See below.
    capacity ConnectorCapacity
    Information about the capacity allocated to the connector. See below.
    connectorConfiguration {[key: string]: string}
    A map of keys to values that represent the configuration for the connector.
    kafkaCluster ConnectorKafkaCluster
    Specifies which Apache Kafka cluster to connect to. See below.
    kafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnectVersion string
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    plugins ConnectorPlugin[]
    Specifies which plugins to use for the connector. See below.
    serviceExecutionRoleArn string
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    description string
    A summary description of the connector.
    logDelivery ConnectorLogDelivery
    Details about log delivery. See below.
    name string
    The name of the connector.
    workerConfiguration ConnectorWorkerConfiguration
    Specifies which worker configuration to use with the connector. See below.
    capacity ConnectorCapacityArgs
    Information about the capacity allocated to the connector. See below.
    connector_configuration Mapping[str, str]
    A map of keys to values that represent the configuration for the connector.
    kafka_cluster ConnectorKafkaClusterArgs
    Specifies which Apache Kafka cluster to connect to. See below.
    kafka_cluster_client_authentication ConnectorKafkaClusterClientAuthenticationArgs
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafka_cluster_encryption_in_transit ConnectorKafkaClusterEncryptionInTransitArgs
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnect_version str
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    plugins Sequence[ConnectorPluginArgs]
    Specifies which plugins to use for the connector. See below.
    service_execution_role_arn str
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    description str
    A summary description of the connector.
    log_delivery ConnectorLogDeliveryArgs
    Details about log delivery. See below.
    name str
    The name of the connector.
    worker_configuration ConnectorWorkerConfigurationArgs
    Specifies which worker configuration to use with the connector. See below.
    capacity Property Map
    Information about the capacity allocated to the connector. See below.
    connectorConfiguration Map<String>
    A map of keys to values that represent the configuration for the connector.
    kafkaCluster Property Map
    Specifies which Apache Kafka cluster to connect to. See below.
    kafkaClusterClientAuthentication Property Map
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafkaClusterEncryptionInTransit Property Map
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnectVersion String
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    plugins List<Property Map>
    Specifies which plugins to use for the connector. See below.
    serviceExecutionRoleArn String
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    description String
    A summary description of the connector.
    logDelivery Property Map
    Details about log delivery. See below.
    name String
    The name of the connector.
    workerConfiguration Property Map
    Specifies which worker configuration to use with the connector. See below.

    Outputs

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

    Arn string
    The Amazon Resource Name (ARN) of the connector.
    Id string
    The provider-assigned unique ID for this managed resource.
    Version string
    The current version of the connector.
    Arn string
    The Amazon Resource Name (ARN) of the connector.
    Id string
    The provider-assigned unique ID for this managed resource.
    Version string
    The current version of the connector.
    arn String
    The Amazon Resource Name (ARN) of the connector.
    id String
    The provider-assigned unique ID for this managed resource.
    version String
    The current version of the connector.
    arn string
    The Amazon Resource Name (ARN) of the connector.
    id string
    The provider-assigned unique ID for this managed resource.
    version string
    The current version of the connector.
    arn str
    The Amazon Resource Name (ARN) of the connector.
    id str
    The provider-assigned unique ID for this managed resource.
    version str
    The current version of the connector.
    arn String
    The Amazon Resource Name (ARN) of the connector.
    id String
    The provider-assigned unique ID for this managed resource.
    version String
    The current version of the connector.

    Look up Existing Connector Resource

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

    public static get(name: string, id: Input<ID>, state?: ConnectorState, opts?: CustomResourceOptions): Connector
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        arn: Optional[str] = None,
        capacity: Optional[ConnectorCapacityArgs] = None,
        connector_configuration: Optional[Mapping[str, str]] = None,
        description: Optional[str] = None,
        kafka_cluster: Optional[ConnectorKafkaClusterArgs] = None,
        kafka_cluster_client_authentication: Optional[ConnectorKafkaClusterClientAuthenticationArgs] = None,
        kafka_cluster_encryption_in_transit: Optional[ConnectorKafkaClusterEncryptionInTransitArgs] = None,
        kafkaconnect_version: Optional[str] = None,
        log_delivery: Optional[ConnectorLogDeliveryArgs] = None,
        name: Optional[str] = None,
        plugins: Optional[Sequence[ConnectorPluginArgs]] = None,
        service_execution_role_arn: Optional[str] = None,
        version: Optional[str] = None,
        worker_configuration: Optional[ConnectorWorkerConfigurationArgs] = None) -> Connector
    func GetConnector(ctx *Context, name string, id IDInput, state *ConnectorState, opts ...ResourceOption) (*Connector, error)
    public static Connector Get(string name, Input<string> id, ConnectorState? state, CustomResourceOptions? opts = null)
    public static Connector get(String name, Output<String> id, ConnectorState state, CustomResourceOptions options)
    Resource lookup is not supported in YAML
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    Arn string
    The Amazon Resource Name (ARN) of the connector.
    Capacity ConnectorCapacity
    Information about the capacity allocated to the connector. See below.
    ConnectorConfiguration Dictionary<string, string>
    A map of keys to values that represent the configuration for the connector.
    Description string
    A summary description of the connector.
    KafkaCluster ConnectorKafkaCluster
    Specifies which Apache Kafka cluster to connect to. See below.
    KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication
    Details of the client authentication used by the Apache Kafka cluster. See below.
    KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit
    Details of encryption in transit to the Apache Kafka cluster. See below.
    KafkaconnectVersion string
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    LogDelivery ConnectorLogDelivery
    Details about log delivery. See below.
    Name string
    The name of the connector.
    Plugins List<ConnectorPlugin>
    Specifies which plugins to use for the connector. See below.
    ServiceExecutionRoleArn string
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    Version string
    The current version of the connector.
    WorkerConfiguration ConnectorWorkerConfiguration
    Specifies which worker configuration to use with the connector. See below.
    Arn string
    The Amazon Resource Name (ARN) of the connector.
    Capacity ConnectorCapacityArgs
    Information about the capacity allocated to the connector. See below.
    ConnectorConfiguration map[string]string
    A map of keys to values that represent the configuration for the connector.
    Description string
    A summary description of the connector.
    KafkaCluster ConnectorKafkaClusterArgs
    Specifies which Apache Kafka cluster to connect to. See below.
    KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationArgs
    Details of the client authentication used by the Apache Kafka cluster. See below.
    KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitArgs
    Details of encryption in transit to the Apache Kafka cluster. See below.
    KafkaconnectVersion string
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    LogDelivery ConnectorLogDeliveryArgs
    Details about log delivery. See below.
    Name string
    The name of the connector.
    Plugins []ConnectorPluginArgs
    Specifies which plugins to use for the connector. See below.
    ServiceExecutionRoleArn string
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    Version string
    The current version of the connector.
    WorkerConfiguration ConnectorWorkerConfigurationArgs
    Specifies which worker configuration to use with the connector. See below.
    arn String
    The Amazon Resource Name (ARN) of the connector.
    capacity ConnectorCapacity
    Information about the capacity allocated to the connector. See below.
    connectorConfiguration Map<String,String>
    A map of keys to values that represent the configuration for the connector.
    description String
    A summary description of the connector.
    kafkaCluster ConnectorKafkaCluster
    Specifies which Apache Kafka cluster to connect to. See below.
    kafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnectVersion String
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    logDelivery ConnectorLogDelivery
    Details about log delivery. See below.
    name String
    The name of the connector.
    plugins List<ConnectorPlugin>
    Specifies which plugins to use for the connector. See below.
    serviceExecutionRoleArn String
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    version String
    The current version of the connector.
    workerConfiguration ConnectorWorkerConfiguration
    Specifies which worker configuration to use with the connector. See below.
    arn string
    The Amazon Resource Name (ARN) of the connector.
    capacity ConnectorCapacity
    Information about the capacity allocated to the connector. See below.
    connectorConfiguration {[key: string]: string}
    A map of keys to values that represent the configuration for the connector.
    description string
    A summary description of the connector.
    kafkaCluster ConnectorKafkaCluster
    Specifies which Apache Kafka cluster to connect to. See below.
    kafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnectVersion string
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    logDelivery ConnectorLogDelivery
    Details about log delivery. See below.
    name string
    The name of the connector.
    plugins ConnectorPlugin[]
    Specifies which plugins to use for the connector. See below.
    serviceExecutionRoleArn string
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    version string
    The current version of the connector.
    workerConfiguration ConnectorWorkerConfiguration
    Specifies which worker configuration to use with the connector. See below.
    arn str
    The Amazon Resource Name (ARN) of the connector.
    capacity ConnectorCapacityArgs
    Information about the capacity allocated to the connector. See below.
    connector_configuration Mapping[str, str]
    A map of keys to values that represent the configuration for the connector.
    description str
    A summary description of the connector.
    kafka_cluster ConnectorKafkaClusterArgs
    Specifies which Apache Kafka cluster to connect to. See below.
    kafka_cluster_client_authentication ConnectorKafkaClusterClientAuthenticationArgs
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafka_cluster_encryption_in_transit ConnectorKafkaClusterEncryptionInTransitArgs
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnect_version str
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    log_delivery ConnectorLogDeliveryArgs
    Details about log delivery. See below.
    name str
    The name of the connector.
    plugins Sequence[ConnectorPluginArgs]
    Specifies which plugins to use for the connector. See below.
    service_execution_role_arn str
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    version str
    The current version of the connector.
    worker_configuration ConnectorWorkerConfigurationArgs
    Specifies which worker configuration to use with the connector. See below.
    arn String
    The Amazon Resource Name (ARN) of the connector.
    capacity Property Map
    Information about the capacity allocated to the connector. See below.
    connectorConfiguration Map<String>
    A map of keys to values that represent the configuration for the connector.
    description String
    A summary description of the connector.
    kafkaCluster Property Map
    Specifies which Apache Kafka cluster to connect to. See below.
    kafkaClusterClientAuthentication Property Map
    Details of the client authentication used by the Apache Kafka cluster. See below.
    kafkaClusterEncryptionInTransit Property Map
    Details of encryption in transit to the Apache Kafka cluster. See below.
    kafkaconnectVersion String
    The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
    logDelivery Property Map
    Details about log delivery. See below.
    name String
    The name of the connector.
    plugins List<Property Map>
    Specifies which plugins to use for the connector. See below.
    serviceExecutionRoleArn String
    The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
    version String
    The current version of the connector.
    workerConfiguration Property Map
    Specifies which worker configuration to use with the connector. See below.

    Supporting Types

    ConnectorCapacity, ConnectorCapacityArgs

    Autoscaling ConnectorCapacityAutoscaling
    Information about the auto scaling parameters for the connector. See below.
    ProvisionedCapacity ConnectorCapacityProvisionedCapacity
    Details about a fixed capacity allocated to a connector. See below.
    Autoscaling ConnectorCapacityAutoscaling
    Information about the auto scaling parameters for the connector. See below.
    ProvisionedCapacity ConnectorCapacityProvisionedCapacity
    Details about a fixed capacity allocated to a connector. See below.
    autoscaling ConnectorCapacityAutoscaling
    Information about the auto scaling parameters for the connector. See below.
    provisionedCapacity ConnectorCapacityProvisionedCapacity
    Details about a fixed capacity allocated to a connector. See below.
    autoscaling ConnectorCapacityAutoscaling
    Information about the auto scaling parameters for the connector. See below.
    provisionedCapacity ConnectorCapacityProvisionedCapacity
    Details about a fixed capacity allocated to a connector. See below.
    autoscaling ConnectorCapacityAutoscaling
    Information about the auto scaling parameters for the connector. See below.
    provisioned_capacity ConnectorCapacityProvisionedCapacity
    Details about a fixed capacity allocated to a connector. See below.
    autoscaling Property Map
    Information about the auto scaling parameters for the connector. See below.
    provisionedCapacity Property Map
    Details about a fixed capacity allocated to a connector. See below.

    ConnectorCapacityAutoscaling, ConnectorCapacityAutoscalingArgs

    MaxWorkerCount int
    The maximum number of workers allocated to the connector.
    MinWorkerCount int
    The minimum number of workers allocated to the connector.
    McuCount int
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    ScaleInPolicy ConnectorCapacityAutoscalingScaleInPolicy
    The scale-in policy for the connector. See below.
    ScaleOutPolicy ConnectorCapacityAutoscalingScaleOutPolicy
    The scale-out policy for the connector. See below.
    MaxWorkerCount int
    The maximum number of workers allocated to the connector.
    MinWorkerCount int
    The minimum number of workers allocated to the connector.
    McuCount int
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    ScaleInPolicy ConnectorCapacityAutoscalingScaleInPolicy
    The scale-in policy for the connector. See below.
    ScaleOutPolicy ConnectorCapacityAutoscalingScaleOutPolicy
    The scale-out policy for the connector. See below.
    maxWorkerCount Integer
    The maximum number of workers allocated to the connector.
    minWorkerCount Integer
    The minimum number of workers allocated to the connector.
    mcuCount Integer
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    scaleInPolicy ConnectorCapacityAutoscalingScaleInPolicy
    The scale-in policy for the connector. See below.
    scaleOutPolicy ConnectorCapacityAutoscalingScaleOutPolicy
    The scale-out policy for the connector. See below.
    maxWorkerCount number
    The maximum number of workers allocated to the connector.
    minWorkerCount number
    The minimum number of workers allocated to the connector.
    mcuCount number
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    scaleInPolicy ConnectorCapacityAutoscalingScaleInPolicy
    The scale-in policy for the connector. See below.
    scaleOutPolicy ConnectorCapacityAutoscalingScaleOutPolicy
    The scale-out policy for the connector. See below.
    max_worker_count int
    The maximum number of workers allocated to the connector.
    min_worker_count int
    The minimum number of workers allocated to the connector.
    mcu_count int
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    scale_in_policy ConnectorCapacityAutoscalingScaleInPolicy
    The scale-in policy for the connector. See below.
    scale_out_policy ConnectorCapacityAutoscalingScaleOutPolicy
    The scale-out policy for the connector. See below.
    maxWorkerCount Number
    The maximum number of workers allocated to the connector.
    minWorkerCount Number
    The minimum number of workers allocated to the connector.
    mcuCount Number
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    scaleInPolicy Property Map
    The scale-in policy for the connector. See below.
    scaleOutPolicy Property Map
    The scale-out policy for the connector. See below.

    ConnectorCapacityAutoscalingScaleInPolicy, ConnectorCapacityAutoscalingScaleInPolicyArgs

    CpuUtilizationPercentage int
    Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
    CpuUtilizationPercentage int
    Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
    cpuUtilizationPercentage Integer
    Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
    cpuUtilizationPercentage number
    Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
    cpu_utilization_percentage int
    Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
    cpuUtilizationPercentage Number
    Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.

    ConnectorCapacityAutoscalingScaleOutPolicy, ConnectorCapacityAutoscalingScaleOutPolicyArgs

    CpuUtilizationPercentage int
    The CPU utilization percentage threshold at which you want connector scale out to be triggered.
    CpuUtilizationPercentage int
    The CPU utilization percentage threshold at which you want connector scale out to be triggered.
    cpuUtilizationPercentage Integer
    The CPU utilization percentage threshold at which you want connector scale out to be triggered.
    cpuUtilizationPercentage number
    The CPU utilization percentage threshold at which you want connector scale out to be triggered.
    cpu_utilization_percentage int
    The CPU utilization percentage threshold at which you want connector scale out to be triggered.
    cpuUtilizationPercentage Number
    The CPU utilization percentage threshold at which you want connector scale out to be triggered.

    ConnectorCapacityProvisionedCapacity, ConnectorCapacityProvisionedCapacityArgs

    WorkerCount int
    The number of workers that are allocated to the connector.
    McuCount int
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    WorkerCount int
    The number of workers that are allocated to the connector.
    McuCount int
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    workerCount Integer
    The number of workers that are allocated to the connector.
    mcuCount Integer
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    workerCount number
    The number of workers that are allocated to the connector.
    mcuCount number
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    worker_count int
    The number of workers that are allocated to the connector.
    mcu_count int
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
    workerCount Number
    The number of workers that are allocated to the connector.
    mcuCount Number
    The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.

    ConnectorKafkaCluster, ConnectorKafkaClusterArgs

    ApacheKafkaCluster ConnectorKafkaClusterApacheKafkaCluster
    The Apache Kafka cluster to which the connector is connected.
    ApacheKafkaCluster ConnectorKafkaClusterApacheKafkaCluster
    The Apache Kafka cluster to which the connector is connected.
    apacheKafkaCluster ConnectorKafkaClusterApacheKafkaCluster
    The Apache Kafka cluster to which the connector is connected.
    apacheKafkaCluster ConnectorKafkaClusterApacheKafkaCluster
    The Apache Kafka cluster to which the connector is connected.
    apache_kafka_cluster ConnectorKafkaClusterApacheKafkaCluster
    The Apache Kafka cluster to which the connector is connected.
    apacheKafkaCluster Property Map
    The Apache Kafka cluster to which the connector is connected.

    ConnectorKafkaClusterApacheKafkaCluster, ConnectorKafkaClusterApacheKafkaClusterArgs

    BootstrapServers string
    The bootstrap servers of the cluster.
    Vpc ConnectorKafkaClusterApacheKafkaClusterVpc
    Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
    BootstrapServers string
    The bootstrap servers of the cluster.
    Vpc ConnectorKafkaClusterApacheKafkaClusterVpc
    Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
    bootstrapServers String
    The bootstrap servers of the cluster.
    vpc ConnectorKafkaClusterApacheKafkaClusterVpc
    Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
    bootstrapServers string
    The bootstrap servers of the cluster.
    vpc ConnectorKafkaClusterApacheKafkaClusterVpc
    Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
    bootstrap_servers str
    The bootstrap servers of the cluster.
    vpc ConnectorKafkaClusterApacheKafkaClusterVpc
    Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
    bootstrapServers String
    The bootstrap servers of the cluster.
    vpc Property Map
    Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

    ConnectorKafkaClusterApacheKafkaClusterVpc, ConnectorKafkaClusterApacheKafkaClusterVpcArgs

    SecurityGroups List<string>
    The security groups for the connector.
    Subnets List<string>
    The subnets for the connector.
    SecurityGroups []string
    The security groups for the connector.
    Subnets []string
    The subnets for the connector.
    securityGroups List<String>
    The security groups for the connector.
    subnets List<String>
    The subnets for the connector.
    securityGroups string[]
    The security groups for the connector.
    subnets string[]
    The subnets for the connector.
    security_groups Sequence[str]
    The security groups for the connector.
    subnets Sequence[str]
    The subnets for the connector.
    securityGroups List<String>
    The security groups for the connector.
    subnets List<String>
    The subnets for the connector.

    ConnectorKafkaClusterClientAuthentication, ConnectorKafkaClusterClientAuthenticationArgs

    AuthenticationType string
    The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
    AuthenticationType string
    The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
    authenticationType String
    The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
    authenticationType string
    The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
    authentication_type str
    The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
    authenticationType String
    The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.

    ConnectorKafkaClusterEncryptionInTransit, ConnectorKafkaClusterEncryptionInTransitArgs

    EncryptionType string
    The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
    EncryptionType string
    The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
    encryptionType String
    The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
    encryptionType string
    The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
    encryption_type str
    The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
    encryptionType String
    The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.

    ConnectorLogDelivery, ConnectorLogDeliveryArgs

    WorkerLogDelivery ConnectorLogDeliveryWorkerLogDelivery
    The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
    WorkerLogDelivery ConnectorLogDeliveryWorkerLogDelivery
    The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
    workerLogDelivery ConnectorLogDeliveryWorkerLogDelivery
    The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
    workerLogDelivery ConnectorLogDeliveryWorkerLogDelivery
    The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
    worker_log_delivery ConnectorLogDeliveryWorkerLogDelivery
    The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
    workerLogDelivery Property Map
    The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.

    ConnectorLogDeliveryWorkerLogDelivery, ConnectorLogDeliveryWorkerLogDeliveryArgs

    CloudwatchLogs ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs
    Details about delivering logs to Amazon CloudWatch Logs. See below.
    Firehose ConnectorLogDeliveryWorkerLogDeliveryFirehose
    Details about delivering logs to Amazon Kinesis Data Firehose. See below.
    S3 ConnectorLogDeliveryWorkerLogDeliveryS3
    Details about delivering logs to Amazon S3. See below.
    CloudwatchLogs ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs
    Details about delivering logs to Amazon CloudWatch Logs. See below.
    Firehose ConnectorLogDeliveryWorkerLogDeliveryFirehose
    Details about delivering logs to Amazon Kinesis Data Firehose. See below.
    S3 ConnectorLogDeliveryWorkerLogDeliveryS3
    Details about delivering logs to Amazon S3. See below.
    cloudwatchLogs ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs
    Details about delivering logs to Amazon CloudWatch Logs. See below.
    firehose ConnectorLogDeliveryWorkerLogDeliveryFirehose
    Details about delivering logs to Amazon Kinesis Data Firehose. See below.
    s3 ConnectorLogDeliveryWorkerLogDeliveryS3
    Details about delivering logs to Amazon S3. See below.
    cloudwatchLogs ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs
    Details about delivering logs to Amazon CloudWatch Logs. See below.
    firehose ConnectorLogDeliveryWorkerLogDeliveryFirehose
    Details about delivering logs to Amazon Kinesis Data Firehose. See below.
    s3 ConnectorLogDeliveryWorkerLogDeliveryS3
    Details about delivering logs to Amazon S3. See below.
    cloudwatch_logs ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs
    Details about delivering logs to Amazon CloudWatch Logs. See below.
    firehose ConnectorLogDeliveryWorkerLogDeliveryFirehose
    Details about delivering logs to Amazon Kinesis Data Firehose. See below.
    s3 ConnectorLogDeliveryWorkerLogDeliveryS3
    Details about delivering logs to Amazon S3. See below.
    cloudwatchLogs Property Map
    Details about delivering logs to Amazon CloudWatch Logs. See below.
    firehose Property Map
    Details about delivering logs to Amazon Kinesis Data Firehose. See below.
    s3 Property Map
    Details about delivering logs to Amazon S3. See below.

    ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs, ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs

    Enabled bool
    Whether log delivery to Amazon CloudWatch Logs is enabled.
    LogGroup string
    The name of the CloudWatch log group that is the destination for log delivery.
    Enabled bool
    Whether log delivery to Amazon CloudWatch Logs is enabled.
    LogGroup string
    The name of the CloudWatch log group that is the destination for log delivery.
    enabled Boolean
    Whether log delivery to Amazon CloudWatch Logs is enabled.
    logGroup String
    The name of the CloudWatch log group that is the destination for log delivery.
    enabled boolean
    Whether log delivery to Amazon CloudWatch Logs is enabled.
    logGroup string
    The name of the CloudWatch log group that is the destination for log delivery.
    enabled bool
    Whether log delivery to Amazon CloudWatch Logs is enabled.
    log_group str
    The name of the CloudWatch log group that is the destination for log delivery.
    enabled Boolean
    Whether log delivery to Amazon CloudWatch Logs is enabled.
    logGroup String
    The name of the CloudWatch log group that is the destination for log delivery.

    ConnectorLogDeliveryWorkerLogDeliveryFirehose, ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs

    Enabled bool
    Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
    DeliveryStream string
    The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
    Enabled bool
    Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
    DeliveryStream string
    The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
    enabled Boolean
    Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
    deliveryStream String
    The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
    enabled boolean
    Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
    deliveryStream string
    The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
    enabled bool
    Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
    delivery_stream str
    The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
    enabled Boolean
    Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
    deliveryStream String
    The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.

    ConnectorLogDeliveryWorkerLogDeliveryS3, ConnectorLogDeliveryWorkerLogDeliveryS3Args

    Enabled bool
    Specifies whether connector logs get sent to the specified Amazon S3 destination.
    Bucket string
    The name of the S3 bucket that is the destination for log delivery.
    Prefix string
    The S3 prefix that is the destination for log delivery.
    Enabled bool
    Specifies whether connector logs get sent to the specified Amazon S3 destination.
    Bucket string
    The name of the S3 bucket that is the destination for log delivery.
    Prefix string
    The S3 prefix that is the destination for log delivery.
    enabled Boolean
    Specifies whether connector logs get sent to the specified Amazon S3 destination.
    bucket String
    The name of the S3 bucket that is the destination for log delivery.
    prefix String
    The S3 prefix that is the destination for log delivery.
    enabled boolean
    Specifies whether connector logs get sent to the specified Amazon S3 destination.
    bucket string
    The name of the S3 bucket that is the destination for log delivery.
    prefix string
    The S3 prefix that is the destination for log delivery.
    enabled bool
    Specifies whether connector logs get sent to the specified Amazon S3 destination.
    bucket str
    The name of the S3 bucket that is the destination for log delivery.
    prefix str
    The S3 prefix that is the destination for log delivery.
    enabled Boolean
    Specifies whether connector logs get sent to the specified Amazon S3 destination.
    bucket String
    The name of the S3 bucket that is the destination for log delivery.
    prefix String
    The S3 prefix that is the destination for log delivery.

    ConnectorPlugin, ConnectorPluginArgs

    CustomPlugin ConnectorPluginCustomPlugin
    Details about a custom plugin. See below.
    CustomPlugin ConnectorPluginCustomPlugin
    Details about a custom plugin. See below.
    customPlugin ConnectorPluginCustomPlugin
    Details about a custom plugin. See below.
    customPlugin ConnectorPluginCustomPlugin
    Details about a custom plugin. See below.
    custom_plugin ConnectorPluginCustomPlugin
    Details about a custom plugin. See below.
    customPlugin Property Map
    Details about a custom plugin. See below.

    ConnectorPluginCustomPlugin, ConnectorPluginCustomPluginArgs

    Arn string
    The Amazon Resource Name (ARN) of the custom plugin.
    Revision int
    The revision of the custom plugin.
    Arn string
    The Amazon Resource Name (ARN) of the custom plugin.
    Revision int
    The revision of the custom plugin.
    arn String
    The Amazon Resource Name (ARN) of the custom plugin.
    revision Integer
    The revision of the custom plugin.
    arn string
    The Amazon Resource Name (ARN) of the custom plugin.
    revision number
    The revision of the custom plugin.
    arn str
    The Amazon Resource Name (ARN) of the custom plugin.
    revision int
    The revision of the custom plugin.
    arn String
    The Amazon Resource Name (ARN) of the custom plugin.
    revision Number
    The revision of the custom plugin.

    ConnectorWorkerConfiguration, ConnectorWorkerConfigurationArgs

    Arn string
    The Amazon Resource Name (ARN) of the worker configuration.
    Revision int
    The revision of the worker configuration.
    Arn string
    The Amazon Resource Name (ARN) of the worker configuration.
    Revision int
    The revision of the worker configuration.
    arn String
    The Amazon Resource Name (ARN) of the worker configuration.
    revision Integer
    The revision of the worker configuration.
    arn string
    The Amazon Resource Name (ARN) of the worker configuration.
    revision number
    The revision of the worker configuration.
    arn str
    The Amazon Resource Name (ARN) of the worker configuration.
    revision int
    The revision of the worker configuration.
    arn String
    The Amazon Resource Name (ARN) of the worker configuration.
    revision Number
    The revision of the worker configuration.

    Import

    Using pulumi import, import MSK Connect Connector using the connector’s arn. For example:

    $ pulumi import aws:mskconnect/connector:Connector example 'arn:aws:kafkaconnect:eu-central-1:123456789012:connector/example/264edee4-17a3-412e-bd76-6681cfc93805-3'

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    AWS Classic pulumi/pulumi-aws
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the aws Terraform Provider.
    aws logo

    Try AWS Native preview for resources not in the classic version.

    AWS Classic v6.42.0 published on Wednesday, Jun 26, 2024 by Pulumi
    pulumi/pulumi-aws