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.4.0 published on Tuesday, Oct 3, 2023 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.4.0 published on Tuesday, Oct 3, 2023 by Pulumi
pulumi/pulumi-aws

    Provides an Amazon MSK Connect Connector resource.

    Example Usage

    Basic configuration

    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()
    {
        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 = aws_msk_cluster.Example.Bootstrap_brokers_tls,
                Vpc = new Aws.MskConnect.Inputs.ConnectorKafkaClusterApacheKafkaClusterVpcArgs
                {
                    SecurityGroups = new[]
                    {
                        aws_security_group.Example.Id,
                    },
                    Subnets = new[]
                    {
                        aws_subnet.Example1.Id,
                        aws_subnet.Example2.Id,
                        aws_subnet.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 = aws_mskconnect_custom_plugin.Example.Arn,
                    Revision = aws_mskconnect_custom_plugin.Example.Latest_revision,
                },
            },
        },
        ServiceExecutionRoleArn = aws_iam_role.Example.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{
			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(aws_msk_cluster.Example.Bootstrap_brokers_tls),
					Vpc: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterVpcArgs{
						SecurityGroups: pulumi.StringArray{
							aws_security_group.Example.Id,
						},
						Subnets: pulumi.StringArray{
							aws_subnet.Example1.Id,
							aws_subnet.Example2.Id,
							aws_subnet.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(aws_mskconnect_custom_plugin.Example.Arn),
						Revision: pulumi.Any(aws_mskconnect_custom_plugin.Example.Latest_revision),
					},
				},
			},
			ServiceExecutionRoleArn: pulumi.Any(aws_iam_role.Example.Arn),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    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()        
            .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(aws_msk_cluster.example().bootstrap_brokers_tls())
                    .vpc(ConnectorKafkaClusterApacheKafkaClusterVpcArgs.builder()
                        .securityGroups(aws_security_group.example().id())
                        .subnets(                        
                            aws_subnet.example1().id(),
                            aws_subnet.example2().id(),
                            aws_subnet.example3().id())
                        .build())
                    .build())
                .build())
            .kafkaClusterClientAuthentication(ConnectorKafkaClusterClientAuthenticationArgs.builder()
                .authenticationType("NONE")
                .build())
            .kafkaClusterEncryptionInTransit(ConnectorKafkaClusterEncryptionInTransitArgs.builder()
                .encryptionType("TLS")
                .build())
            .plugins(ConnectorPluginArgs.builder()
                .customPlugin(ConnectorPluginCustomPluginArgs.builder()
                    .arn(aws_mskconnect_custom_plugin.example().arn())
                    .revision(aws_mskconnect_custom_plugin.example().latest_revision())
                    .build())
                .build())
            .serviceExecutionRoleArn(aws_iam_role.example().arn())
            .build());

    }
}

    import pulumi
import pulumi_aws as aws

example = aws.mskconnect.Connector("example",
    kafkaconnect_version="2.7.1",
    capacity=aws.mskconnect.ConnectorCapacityArgs(
        autoscaling=aws.mskconnect.ConnectorCapacityAutoscalingArgs(
            mcu_count=1,
            min_worker_count=1,
            max_worker_count=2,
            scale_in_policy=aws.mskconnect.ConnectorCapacityAutoscalingScaleInPolicyArgs(
                cpu_utilization_percentage=20,
            ),
            scale_out_policy=aws.mskconnect.ConnectorCapacityAutoscalingScaleOutPolicyArgs(
                cpu_utilization_percentage=80,
            ),
        ),
    ),
    connector_configuration={
        "connector.class": "com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector",
        "tasks.max": "1",
        "topics": "example",
    },
    kafka_cluster=aws.mskconnect.ConnectorKafkaClusterArgs(
        apache_kafka_cluster=aws.mskconnect.ConnectorKafkaClusterApacheKafkaClusterArgs(
            bootstrap_servers=aws_msk_cluster["example"]["bootstrap_brokers_tls"],
            vpc=aws.mskconnect.ConnectorKafkaClusterApacheKafkaClusterVpcArgs(
                security_groups=[aws_security_group["example"]["id"]],
                subnets=[
                    aws_subnet["example1"]["id"],
                    aws_subnet["example2"]["id"],
                    aws_subnet["example3"]["id"],
                ],
            ),
        ),
    ),
    kafka_cluster_client_authentication=aws.mskconnect.ConnectorKafkaClusterClientAuthenticationArgs(
        authentication_type="NONE",
    ),
    kafka_cluster_encryption_in_transit=aws.mskconnect.ConnectorKafkaClusterEncryptionInTransitArgs(
        encryption_type="TLS",
    ),
    plugins=[aws.mskconnect.ConnectorPluginArgs(
        custom_plugin=aws.mskconnect.ConnectorPluginCustomPluginArgs(
            arn=aws_mskconnect_custom_plugin["example"]["arn"],
            revision=aws_mskconnect_custom_plugin["example"]["latest_revision"],
        ),
    )],
    service_execution_role_arn=aws_iam_role["example"]["arn"])

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

const example = new aws.mskconnect.Connector("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: aws_msk_cluster.example.bootstrap_brokers_tls,
            vpc: {
                securityGroups: [aws_security_group.example.id],
                subnets: [
                    aws_subnet.example1.id,
                    aws_subnet.example2.id,
                    aws_subnet.example3.id,
                ],
            },
        },
    },
    kafkaClusterClientAuthentication: {
        authenticationType: "NONE",
    },
    kafkaClusterEncryptionInTransit: {
        encryptionType: "TLS",
    },
    plugins: [{
        customPlugin: {
            arn: aws_mskconnect_custom_plugin.example.arn,
            revision: aws_mskconnect_custom_plugin.example.latest_revision,
        },
    }],
    serviceExecutionRoleArn: aws_iam_role.example.arn,
});

    resources:
  example:
    type: aws:mskconnect:Connector
    properties:
      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: ${aws_msk_cluster.example.bootstrap_brokers_tls}
          vpc:
            securityGroups:
              - ${aws_security_group.example.id}
            subnets:
              - ${aws_subnet.example1.id}
              - ${aws_subnet.example2.id}
              - ${aws_subnet.example3.id}
      kafkaClusterClientAuthentication:
        authenticationType: NONE
      kafkaClusterEncryptionInTransit:
        encryptionType: TLS
      plugins:
        - customPlugin:
            arn: ${aws_mskconnect_custom_plugin.example.arn}
            revision: ${aws_mskconnect_custom_plugin.example.latest_revision}
      serviceExecutionRoleArn: ${aws_iam_role.example.arn}

    Create Connector Resource

    new Connector(name: string, args: ConnectorArgs, opts?: CustomResourceOptions);
    @overload
def Connector(resource_name: str,
              opts: Optional[ResourceOptions] = 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,
              worker_configuration: Optional[ConnectorWorkerConfigurationArgs] = None)
@overload
def Connector(resource_name: str,
              args: ConnectorArgs,
              opts: Optional[ResourceOptions] = 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.
    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.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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 custom plugin.

    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

    Whether log delivery to Amazon CloudWatch Logs is enabled.

    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

    Whether log delivery to Amazon CloudWatch Logs is enabled.

    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

    Whether log delivery to Amazon CloudWatch Logs is enabled.

    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

    Whether log delivery to Amazon CloudWatch Logs is enabled.

    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

    Whether log delivery to Amazon CloudWatch Logs is enabled.

    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

    Whether log delivery to Amazon CloudWatch Logs is enabled.

    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'

    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.4.0 published on Tuesday, Oct 3, 2023 by Pulumi
    pulumi/pulumi-aws