Docs Packages
  1. Pulumi Registry
  2. AWS Classic
  3. API Docs
  4. mskconnect
  5. Connector
aws logo
AWS Classic v5.41.0, May 15 23

aws.mskconnect.Connector

Explore with Pulumi AI

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/v5/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 ConnectorCapacityArgs

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 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 List<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 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 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 List<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 ConnectorCapacityArgs

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 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 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 ConnectorCapacityArgs

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 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 List<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 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 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 List<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 ConnectorCapacityArgs

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 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 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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

MSK Connect Connector can be imported using the connector’s arn, e.g.,

 $ 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.