AWS Cloud Control v1.27.0, Apr 14 25

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

AWS Cloud Control v1.27.0 published on Monday, Apr 14, 2025 by Pulumi

aws-native.kafkaconnect.Connector

Explore with Pulumi AI

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

AWS Cloud Control v1.27.0 published on Monday, Apr 14, 2025 by Pulumi

Create Connector Resource

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

new Connector(name: string, args: ConnectorArgs, opts?: CustomResourceOptions);

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

@overload
def Connector(resource_name: str,
              opts: Optional[ResourceOptions] = None,
              plugins: Optional[Sequence[ConnectorPluginArgs]] = None,
              connector_configuration: Optional[Mapping[str, str]] = None,
              kafka_cluster: Optional[ConnectorKafkaClusterArgs] = None,
              kafka_cluster_client_authentication: Optional[ConnectorKafkaClusterClientAuthenticationArgs] = None,
              kafka_cluster_encryption_in_transit: Optional[ConnectorKafkaClusterEncryptionInTransitArgs] = None,
              kafka_connect_version: Optional[str] = None,
              capacity: Optional[ConnectorCapacityArgs] = None,
              service_execution_role_arn: Optional[str] = None,
              connector_description: Optional[str] = None,
              connector_name: Optional[str] = None,
              log_delivery: Optional[ConnectorLogDeliveryArgs] = None,
              tags: Optional[Sequence[_root_inputs.TagArgs]] = None,
              worker_configuration: Optional[ConnectorWorkerConfigurationArgs] = None)

func NewConnector(ctx *Context, name string, args ConnectorArgs, opts ...ResourceOption) (*Connector, error)

public Connector(string name, ConnectorArgs args, CustomResourceOptions? opts = null)

public Connector(String name, ConnectorArgs args)
public Connector(String name, ConnectorArgs args, CustomResourceOptions options)

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

Parameters

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

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

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

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

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

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

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

The Connector resource accepts the following input properties:

Capacity Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorCapacity: The connector's compute capacity settings.
ConnectorConfiguration Dictionary<string, string>: The configuration for the connector.
KafkaCluster Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorKafkaCluster: The details of the Apache Kafka cluster to which the connector is connected.
KafkaClusterClientAuthentication Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorKafkaClusterClientAuthentication: The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used.
KafkaClusterEncryptionInTransit Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
KafkaConnectVersion string: The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
Plugins List<Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorPlugin>: List of plugins to use with the connector.
ServiceExecutionRoleArn string: The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
ConnectorDescription string: A summary description of the connector.
ConnectorName string: The name of the connector.
LogDelivery Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorLogDelivery: The settings for delivering connector logs to Amazon CloudWatch Logs.
Tags List<Pulumi.AwsNative.Inputs.Tag>: A collection of tags associated with a resource
WorkerConfiguration Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorWorkerConfiguration: The worker configurations that are in use with the connector.

Capacity ConnectorCapacityArgs: The connector's compute capacity settings.
ConnectorConfiguration map[string]string: The configuration for the connector.
KafkaCluster ConnectorKafkaClusterArgs: The details of the Apache Kafka cluster to which the connector is connected.
KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationArgs: The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used.
KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitArgs: Details of encryption in transit to the Apache Kafka cluster.
KafkaConnectVersion string: The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
Plugins []ConnectorPluginArgs: List of plugins to use with the connector.
ServiceExecutionRoleArn string: The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
ConnectorDescription string: A summary description of the connector.
ConnectorName string: The name of the connector.
LogDelivery ConnectorLogDeliveryArgs: The settings for delivering connector logs to Amazon CloudWatch Logs.
Tags TagArgs: A collection of tags associated with a resource
WorkerConfiguration ConnectorWorkerConfigurationArgs: The worker configurations that are in use with the connector.

capacity ConnectorCapacity: The connector's compute capacity settings.
connectorConfiguration Map<String,String>: The configuration for the connector.
kafkaCluster ConnectorKafkaCluster: The details of the Apache Kafka cluster to which the connector is connected.
kafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication: The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used.
kafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
kafkaConnectVersion String: The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
plugins List<ConnectorPlugin>: List of plugins to use with the connector.
serviceExecutionRoleArn String: The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
connectorDescription String: A summary description of the connector.
connectorName String: The name of the connector.
logDelivery ConnectorLogDelivery: The settings for delivering connector logs to Amazon CloudWatch Logs.
tags List<Tag>: A collection of tags associated with a resource
workerConfiguration ConnectorWorkerConfiguration: The worker configurations that are in use with the connector.

capacity ConnectorCapacity: The connector's compute capacity settings.
connectorConfiguration {[key: string]: string}: The configuration for the connector.
kafkaCluster ConnectorKafkaCluster: The details of the Apache Kafka cluster to which the connector is connected.
kafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthentication: The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used.
kafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
kafkaConnectVersion string: The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
plugins ConnectorPlugin[]: List of plugins to use with the connector.
serviceExecutionRoleArn string: The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
connectorDescription string: A summary description of the connector.
connectorName string: The name of the connector.
logDelivery ConnectorLogDelivery: The settings for delivering connector logs to Amazon CloudWatch Logs.
tags Tag[]: A collection of tags associated with a resource
workerConfiguration ConnectorWorkerConfiguration: The worker configurations that are in use with the connector.

capacity ConnectorCapacityArgs: The connector's compute capacity settings.
connector_configuration Mapping[str, str]: The configuration for the connector.
kafka_cluster ConnectorKafkaClusterArgs: The details of the Apache Kafka cluster to which the connector is connected.
kafka_cluster_client_authentication ConnectorKafkaClusterClientAuthenticationArgs: The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used.
kafka_cluster_encryption_in_transit ConnectorKafkaClusterEncryptionInTransitArgs: Details of encryption in transit to the Apache Kafka cluster.
kafka_connect_version str: The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
plugins Sequence[ConnectorPluginArgs]: List of plugins to use with the connector.
service_execution_role_arn str: The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
connector_description str: A summary description of the connector.
connector_name str: The name of the connector.
log_delivery ConnectorLogDeliveryArgs: The settings for delivering connector logs to Amazon CloudWatch Logs.
tags Sequence[TagArgs]: A collection of tags associated with a resource
worker_configuration ConnectorWorkerConfigurationArgs: The worker configurations that are in use with the connector.

capacity Property Map: The connector's compute capacity settings.
connectorConfiguration Map<String>: The configuration for the connector.
kafkaCluster Property Map: The details of the Apache Kafka cluster to which the connector is connected.
kafkaClusterClientAuthentication Property Map: The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used.
kafkaClusterEncryptionInTransit Property Map: Details of encryption in transit to the Apache Kafka cluster.
kafkaConnectVersion String: The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
plugins List<Property Map>: List of plugins to use with the connector.
serviceExecutionRoleArn String: The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
connectorDescription String: A summary description of the connector.
connectorName String: The name of the connector.
logDelivery Property Map: The settings for delivering connector logs to Amazon CloudWatch Logs.
tags List<Property Map>: A collection of tags associated with a resource
workerConfiguration Property Map: The worker configurations that are in use with the connector.

Outputs

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

ConnectorArn string: Amazon Resource Name for the created Connector.
Id string: The provider-assigned unique ID for this managed resource.

ConnectorArn string: Amazon Resource Name for the created Connector.
Id string: The provider-assigned unique ID for this managed resource.

connectorArn String: Amazon Resource Name for the created Connector.
id String: The provider-assigned unique ID for this managed resource.

connectorArn string: Amazon Resource Name for the created Connector.
id string: The provider-assigned unique ID for this managed resource.

connector_arn str: Amazon Resource Name for the created Connector.
id str: The provider-assigned unique ID for this managed resource.

connectorArn String: Amazon Resource Name for the created Connector.
id String: The provider-assigned unique ID for this managed resource.

Supporting Types

ConnectorApacheKafkaCluster
, ConnectorApacheKafkaClusterArgs

BootstrapServers string: The bootstrap servers string of the Apache Kafka cluster.
Vpc Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorVpc: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

BootstrapServers string: The bootstrap servers string of the Apache Kafka cluster.
Vpc ConnectorVpc: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

bootstrapServers String: The bootstrap servers string of the Apache Kafka cluster.
vpc ConnectorVpc: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

bootstrapServers string: The bootstrap servers string of the Apache Kafka cluster.
vpc ConnectorVpc: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

bootstrap_servers str: The bootstrap servers string of the Apache Kafka cluster.
vpc ConnectorVpc: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

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

ConnectorAutoScaling
, ConnectorAutoScalingArgs

MaxWorkerCount int: The maximum number of workers for a connector.
McuCount int: Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
MinWorkerCount int: The minimum number of workers for a connector.
ScaleInPolicy Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorScaleInPolicy: The sacle-in policy for the connector.
ScaleOutPolicy Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorScaleOutPolicy: The sacle-out policy for the connector.

MaxWorkerCount int: The maximum number of workers for a connector.
McuCount int: Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
MinWorkerCount int: The minimum number of workers for a connector.
ScaleInPolicy ConnectorScaleInPolicy: The sacle-in policy for the connector.
ScaleOutPolicy ConnectorScaleOutPolicy: The sacle-out policy for the connector.

maxWorkerCount Integer: The maximum number of workers for a connector.
mcuCount Integer: Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
minWorkerCount Integer: The minimum number of workers for a connector.
scaleInPolicy ConnectorScaleInPolicy: The sacle-in policy for the connector.
scaleOutPolicy ConnectorScaleOutPolicy: The sacle-out policy for the connector.

maxWorkerCount number: The maximum number of workers for a connector.
mcuCount number: Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
minWorkerCount number: The minimum number of workers for a connector.
scaleInPolicy ConnectorScaleInPolicy: The sacle-in policy for the connector.
scaleOutPolicy ConnectorScaleOutPolicy: The sacle-out policy for the connector.

max_worker_count int: The maximum number of workers for a connector.
mcu_count int: Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
min_worker_count int: The minimum number of workers for a connector.
scale_in_policy ConnectorScaleInPolicy: The sacle-in policy for the connector.
scale_out_policy ConnectorScaleOutPolicy: The sacle-out policy for the connector.

maxWorkerCount Number: The maximum number of workers for a connector.
mcuCount Number: Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
minWorkerCount Number: The minimum number of workers for a connector.
scaleInPolicy Property Map: The sacle-in policy for the connector.
scaleOutPolicy Property Map: The sacle-out policy for the connector.

ConnectorCapacity
, ConnectorCapacityArgs

AutoScaling Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorAutoScaling: Information about the auto scaling parameters for the connector.
ProvisionedCapacity Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorProvisionedCapacity: Details about a fixed capacity allocated to a connector.

AutoScaling ConnectorAutoScaling: Information about the auto scaling parameters for the connector.
ProvisionedCapacity ConnectorProvisionedCapacity: Details about a fixed capacity allocated to a connector.

autoScaling ConnectorAutoScaling: Information about the auto scaling parameters for the connector.
provisionedCapacity ConnectorProvisionedCapacity: Details about a fixed capacity allocated to a connector.

autoScaling ConnectorAutoScaling: Information about the auto scaling parameters for the connector.
provisionedCapacity ConnectorProvisionedCapacity: Details about a fixed capacity allocated to a connector.

auto_scaling ConnectorAutoScaling: Information about the auto scaling parameters for the connector.
provisioned_capacity ConnectorProvisionedCapacity: Details about a fixed capacity allocated to a connector.

autoScaling Property Map: Information about the auto scaling parameters for the connector.
provisionedCapacity Property Map: Details about a fixed capacity allocated to a connector.

ConnectorCloudWatchLogsLogDelivery
, ConnectorCloudWatchLogsLogDeliveryArgs

Enabled bool: Specifies whether the logs get sent to the specified CloudWatch Logs destination.
LogGroup string: The CloudWatch log group that is the destination for log delivery.

Enabled bool: Specifies whether the logs get sent to the specified CloudWatch Logs destination.
LogGroup string: The CloudWatch log group that is the destination for log delivery.

enabled Boolean: Specifies whether the logs get sent to the specified CloudWatch Logs destination.
logGroup String: The CloudWatch log group that is the destination for log delivery.

enabled boolean: Specifies whether the logs get sent to the specified CloudWatch Logs destination.
logGroup string: The CloudWatch log group that is the destination for log delivery.

enabled bool: Specifies whether the logs get sent to the specified CloudWatch Logs destination.
log_group str: The CloudWatch log group that is the destination for log delivery.

enabled Boolean: Specifies whether the logs get sent to the specified CloudWatch Logs destination.
logGroup String: The CloudWatch log group that is the destination for log delivery.

ConnectorCustomPlugin
, ConnectorCustomPluginArgs

CustomPluginArn string: The Amazon Resource Name (ARN) of the custom plugin to use.
Revision int: The revision of the custom plugin to use.

CustomPluginArn string: The Amazon Resource Name (ARN) of the custom plugin to use.
Revision int: The revision of the custom plugin to use.

customPluginArn String: The Amazon Resource Name (ARN) of the custom plugin to use.
revision Integer: The revision of the custom plugin to use.

customPluginArn string: The Amazon Resource Name (ARN) of the custom plugin to use.
revision number: The revision of the custom plugin to use.

custom_plugin_arn str: The Amazon Resource Name (ARN) of the custom plugin to use.
revision int: The revision of the custom plugin to use.

customPluginArn String: The Amazon Resource Name (ARN) of the custom plugin to use.
revision Number: The revision of the custom plugin to use.

ConnectorFirehoseLogDelivery
, ConnectorFirehoseLogDeliveryArgs

Enabled bool: Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
DeliveryStream string: The Kinesis Data Firehose delivery stream that is the destination for log delivery.

Enabled bool: Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
DeliveryStream string: The Kinesis Data Firehose delivery stream that is the destination for log delivery.

enabled Boolean: Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
deliveryStream String: The Kinesis Data Firehose delivery stream that is the destination for log delivery.

enabled boolean: Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
deliveryStream string: The Kinesis Data Firehose delivery stream that is the destination for log delivery.

enabled bool: Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
delivery_stream str: The Kinesis Data Firehose delivery stream that is the destination for log delivery.

enabled Boolean: Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
deliveryStream String: The Kinesis Data Firehose delivery stream that is the destination for log delivery.

ConnectorKafkaCluster
, ConnectorKafkaClusterArgs

ApacheKafkaCluster Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorApacheKafkaCluster: The Apache Kafka cluster to which the connector is connected.

ApacheKafkaCluster ConnectorApacheKafkaCluster: The Apache Kafka cluster to which the connector is connected.

apacheKafkaCluster ConnectorApacheKafkaCluster: The Apache Kafka cluster to which the connector is connected.

apacheKafkaCluster ConnectorApacheKafkaCluster: The Apache Kafka cluster to which the connector is connected.

apache_kafka_cluster ConnectorApacheKafkaCluster: The Apache Kafka cluster to which the connector is connected.

apacheKafkaCluster Property Map: The Apache Kafka cluster to which the connector is connected.

ConnectorKafkaClusterClientAuthentication
, ConnectorKafkaClusterClientAuthenticationArgs

AuthenticationType Pulumi.AwsNative.KafkaConnect.ConnectorKafkaClusterClientAuthenticationType: The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used.

AuthenticationType ConnectorKafkaClusterClientAuthenticationType: The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used.

authenticationType ConnectorKafkaClusterClientAuthenticationType: The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used.

authenticationType ConnectorKafkaClusterClientAuthenticationType: The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used.

authentication_type ConnectorKafkaClusterClientAuthenticationType: The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used.

authenticationType "NONE" | "IAM": The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used.

ConnectorKafkaClusterClientAuthenticationType
, ConnectorKafkaClusterClientAuthenticationTypeArgs

None: NONE
Iam: IAM

ConnectorKafkaClusterClientAuthenticationTypeNone: NONE
ConnectorKafkaClusterClientAuthenticationTypeIam: IAM

None: NONE
Iam: IAM

None: NONE
Iam: IAM

NONE: NONE
IAM: IAM

"NONE": NONE
"IAM": IAM

ConnectorKafkaClusterEncryptionInTransit
, ConnectorKafkaClusterEncryptionInTransitArgs

EncryptionType Pulumi.AwsNative.KafkaConnect.ConnectorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.

EncryptionType ConnectorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.

encryptionType ConnectorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.

encryptionType ConnectorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.

encryption_type ConnectorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.

encryptionType "PLAINTEXT" | "TLS": The type of encryption in transit to the Apache Kafka cluster.

ConnectorKafkaClusterEncryptionInTransitType
, ConnectorKafkaClusterEncryptionInTransitTypeArgs

Plaintext: PLAINTEXT
Tls: TLS

ConnectorKafkaClusterEncryptionInTransitTypePlaintext: PLAINTEXT
ConnectorKafkaClusterEncryptionInTransitTypeTls: TLS

Plaintext: PLAINTEXT
Tls: TLS

Plaintext: PLAINTEXT
Tls: TLS

PLAINTEXT: PLAINTEXT
TLS: TLS

"PLAINTEXT": PLAINTEXT
"TLS": TLS

ConnectorLogDelivery
, ConnectorLogDeliveryArgs

WorkerLogDelivery Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorWorkerLogDelivery: The workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

WorkerLogDelivery ConnectorWorkerLogDelivery: The workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

workerLogDelivery ConnectorWorkerLogDelivery: The workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

workerLogDelivery ConnectorWorkerLogDelivery: The workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

worker_log_delivery ConnectorWorkerLogDelivery: The workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

workerLogDelivery Property Map: The workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

ConnectorPlugin
, ConnectorPluginArgs

CustomPlugin Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorCustomPlugin: Details about a custom plugin.

CustomPlugin ConnectorCustomPlugin: Details about a custom plugin.

customPlugin ConnectorCustomPlugin: Details about a custom plugin.

customPlugin ConnectorCustomPlugin: Details about a custom plugin.

custom_plugin ConnectorCustomPlugin: Details about a custom plugin.

customPlugin Property Map: Details about a custom plugin.

ConnectorProvisionedCapacity
, ConnectorProvisionedCapacityArgs

WorkerCount int: Number of workers for a connector.
McuCount int: Specifies how many MSK Connect Units (MCU) are allocated to the connector.

WorkerCount int: Number of workers for a connector.
McuCount int: Specifies how many MSK Connect Units (MCU) are allocated to the connector.

workerCount Integer: Number of workers for a connector.
mcuCount Integer: Specifies how many MSK Connect Units (MCU) are allocated to the connector.

workerCount number: Number of workers for a connector.
mcuCount number: Specifies how many MSK Connect Units (MCU) are allocated to the connector.

worker_count int: Number of workers for a connector.
mcu_count int: Specifies how many MSK Connect Units (MCU) are allocated to the connector.

workerCount Number: Number of workers for a connector.
mcuCount Number: Specifies how many MSK Connect Units (MCU) are allocated to the connector.

ConnectorS3LogDelivery
, ConnectorS3LogDeliveryArgs

Enabled bool: Specifies whether the logs get sent to the specified Amazon S3 destination.
Bucket string: The name of the S3 bucket that is the destination for log delivery.
Prefix string: The S3 prefix that is the destination for log delivery.

Enabled bool: Specifies whether the logs get sent to the specified Amazon S3 destination.
Bucket string: The name of the S3 bucket that is the destination for log delivery.
Prefix string: The S3 prefix that is the destination for log delivery.

enabled Boolean: Specifies whether the logs get sent to the specified Amazon S3 destination.
bucket String: The name of the S3 bucket that is the destination for log delivery.
prefix String: The S3 prefix that is the destination for log delivery.

enabled boolean: Specifies whether the logs get sent to the specified Amazon S3 destination.
bucket string: The name of the S3 bucket that is the destination for log delivery.
prefix string: The S3 prefix that is the destination for log delivery.

enabled bool: Specifies whether the logs get sent to the specified Amazon S3 destination.
bucket str: The name of the S3 bucket that is the destination for log delivery.
prefix str: The S3 prefix that is the destination for log delivery.

enabled Boolean: Specifies whether the logs get sent to the specified Amazon S3 destination.
bucket String: The name of the S3 bucket that is the destination for log delivery.
prefix String: The S3 prefix that is the destination for log delivery.

ConnectorScaleInPolicy
, ConnectorScaleInPolicyArgs

CpuUtilizationPercentage int: Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

CpuUtilizationPercentage int: Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

cpuUtilizationPercentage Integer: Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

cpuUtilizationPercentage number: Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

cpu_utilization_percentage int: Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

cpuUtilizationPercentage Number: Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

ConnectorScaleOutPolicy
, ConnectorScaleOutPolicyArgs

CpuUtilizationPercentage int: Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

CpuUtilizationPercentage int: Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

cpuUtilizationPercentage Integer: Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

cpuUtilizationPercentage number: Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

cpu_utilization_percentage int: Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

cpuUtilizationPercentage Number: Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

ConnectorVpc
, ConnectorVpcArgs

SecurityGroups List<string>: The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
Subnets List<string>: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

SecurityGroups []string: The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
Subnets []string: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

securityGroups List<String>: The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
subnets List<String>: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

securityGroups string[]: The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
subnets string[]: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

security_groups Sequence[str]: The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
subnets Sequence[str]: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

securityGroups List<String>: The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
subnets List<String>: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

ConnectorWorkerConfiguration
, ConnectorWorkerConfigurationArgs

Revision int: The revision of the worker configuration to use.
WorkerConfigurationArn string: The Amazon Resource Name (ARN) of the worker configuration to use.

Revision int: The revision of the worker configuration to use.
WorkerConfigurationArn string: The Amazon Resource Name (ARN) of the worker configuration to use.

revision Integer: The revision of the worker configuration to use.
workerConfigurationArn String: The Amazon Resource Name (ARN) of the worker configuration to use.

revision number: The revision of the worker configuration to use.
workerConfigurationArn string: The Amazon Resource Name (ARN) of the worker configuration to use.

revision int: The revision of the worker configuration to use.
worker_configuration_arn str: The Amazon Resource Name (ARN) of the worker configuration to use.

revision Number: The revision of the worker configuration to use.
workerConfigurationArn String: The Amazon Resource Name (ARN) of the worker configuration to use.

ConnectorWorkerLogDelivery
, ConnectorWorkerLogDeliveryArgs

CloudWatchLogs Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorCloudWatchLogsLogDelivery: Details about delivering logs to Amazon CloudWatch Logs.
Firehose Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorFirehoseLogDelivery: Details about delivering logs to Amazon Kinesis Data Firehose.
S3 Pulumi.AwsNative.KafkaConnect.Inputs.ConnectorS3LogDelivery: Details about delivering logs to Amazon S3.

CloudWatchLogs ConnectorCloudWatchLogsLogDelivery: Details about delivering logs to Amazon CloudWatch Logs.
Firehose ConnectorFirehoseLogDelivery: Details about delivering logs to Amazon Kinesis Data Firehose.
S3 ConnectorS3LogDelivery: Details about delivering logs to Amazon S3.

cloudWatchLogs ConnectorCloudWatchLogsLogDelivery: Details about delivering logs to Amazon CloudWatch Logs.
firehose ConnectorFirehoseLogDelivery: Details about delivering logs to Amazon Kinesis Data Firehose.
s3 ConnectorS3LogDelivery: Details about delivering logs to Amazon S3.

cloudWatchLogs ConnectorCloudWatchLogsLogDelivery: Details about delivering logs to Amazon CloudWatch Logs.
firehose ConnectorFirehoseLogDelivery: Details about delivering logs to Amazon Kinesis Data Firehose.
s3 ConnectorS3LogDelivery: Details about delivering logs to Amazon S3.

cloud_watch_logs ConnectorCloudWatchLogsLogDelivery: Details about delivering logs to Amazon CloudWatch Logs.
firehose ConnectorFirehoseLogDelivery: Details about delivering logs to Amazon Kinesis Data Firehose.
s3 ConnectorS3LogDelivery: Details about delivering logs to Amazon S3.

cloudWatchLogs Property Map: Details about delivering logs to Amazon CloudWatch Logs.
firehose Property Map: Details about delivering logs to Amazon Kinesis Data Firehose.
s3 Property Map: Details about delivering logs to Amazon S3.

Tag
, TagArgs

Key string: The key name of the tag
Value string: The value of the tag

Key string: The key name of the tag
Value string: The value of the tag

key String: The key name of the tag
value String: The value of the tag

key string: The key name of the tag
value string: The value of the tag

key str: The key name of the tag
value str: The value of the tag

key String: The key name of the tag
value String: The value of the tag

Package Details

Repository: AWS Native pulumi/pulumi-aws-native
License: Apache-2.0

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

AWS Cloud Control v1.27.0 published on Monday, Apr 14, 2025 by Pulumi

pulumi/pulumi-aws-native

aws-native.kafkaconnect.Connector

On this page

On this page

Create Connector Resource

Constructor syntax

Parameters

Connector Resource Properties

Inputs

Outputs

Supporting Types

ConnectorApacheKafkaCluster
, ConnectorApacheKafkaClusterArgs

ConnectorAutoScaling
, ConnectorAutoScalingArgs

ConnectorCapacity
, ConnectorCapacityArgs

ConnectorCloudWatchLogsLogDelivery
, ConnectorCloudWatchLogsLogDeliveryArgs

ConnectorCustomPlugin
, ConnectorCustomPluginArgs

ConnectorFirehoseLogDelivery
, ConnectorFirehoseLogDeliveryArgs

ConnectorKafkaCluster
, ConnectorKafkaClusterArgs

ConnectorKafkaClusterClientAuthentication
, ConnectorKafkaClusterClientAuthenticationArgs

ConnectorKafkaClusterClientAuthenticationType
, ConnectorKafkaClusterClientAuthenticationTypeArgs

ConnectorKafkaClusterEncryptionInTransit
, ConnectorKafkaClusterEncryptionInTransitArgs

ConnectorKafkaClusterEncryptionInTransitType
, ConnectorKafkaClusterEncryptionInTransitTypeArgs

ConnectorLogDelivery
, ConnectorLogDeliveryArgs

ConnectorPlugin
, ConnectorPluginArgs

ConnectorProvisionedCapacity
, ConnectorProvisionedCapacityArgs

ConnectorS3LogDelivery
, ConnectorS3LogDeliveryArgs

ConnectorScaleInPolicy
, ConnectorScaleInPolicyArgs

ConnectorScaleOutPolicy
, ConnectorScaleOutPolicyArgs

ConnectorVpc
, ConnectorVpcArgs

ConnectorWorkerConfiguration
, ConnectorWorkerConfigurationArgs

ConnectorWorkerLogDelivery
, ConnectorWorkerLogDeliveryArgs

Tag
, TagArgs

Package Details

On this page

On this page

aws-native.kafkaconnect.Connector

On this page

On this page

Create Connector Resource

Constructor syntax

Parameters

Connector Resource Properties

Inputs

Outputs

Supporting Types

ConnectorApacheKafkaCluster, ConnectorApacheKafkaClusterArgs

ConnectorAutoScaling, ConnectorAutoScalingArgs

ConnectorCapacity, ConnectorCapacityArgs

ConnectorCloudWatchLogsLogDelivery, ConnectorCloudWatchLogsLogDeliveryArgs

ConnectorCustomPlugin, ConnectorCustomPluginArgs

ConnectorFirehoseLogDelivery, ConnectorFirehoseLogDeliveryArgs

ConnectorKafkaCluster, ConnectorKafkaClusterArgs

ConnectorKafkaClusterClientAuthentication, ConnectorKafkaClusterClientAuthenticationArgs

ConnectorKafkaClusterClientAuthenticationType, ConnectorKafkaClusterClientAuthenticationTypeArgs

ConnectorKafkaClusterEncryptionInTransit, ConnectorKafkaClusterEncryptionInTransitArgs

ConnectorKafkaClusterEncryptionInTransitType, ConnectorKafkaClusterEncryptionInTransitTypeArgs

ConnectorLogDelivery, ConnectorLogDeliveryArgs

ConnectorPlugin, ConnectorPluginArgs

ConnectorProvisionedCapacity, ConnectorProvisionedCapacityArgs

ConnectorS3LogDelivery, ConnectorS3LogDeliveryArgs

ConnectorScaleInPolicy, ConnectorScaleInPolicyArgs

ConnectorScaleOutPolicy, ConnectorScaleOutPolicyArgs

ConnectorVpc, ConnectorVpcArgs

ConnectorWorkerConfiguration, ConnectorWorkerConfigurationArgs

ConnectorWorkerLogDelivery, ConnectorWorkerLogDeliveryArgs

Tag, TagArgs

Package Details

On this page

On this page

ConnectorApacheKafkaCluster
, ConnectorApacheKafkaClusterArgs

ConnectorAutoScaling
, ConnectorAutoScalingArgs

ConnectorCapacity
, ConnectorCapacityArgs

ConnectorCloudWatchLogsLogDelivery
, ConnectorCloudWatchLogsLogDeliveryArgs

ConnectorCustomPlugin
, ConnectorCustomPluginArgs

ConnectorFirehoseLogDelivery
, ConnectorFirehoseLogDeliveryArgs

ConnectorKafkaCluster
, ConnectorKafkaClusterArgs

ConnectorKafkaClusterClientAuthentication
, ConnectorKafkaClusterClientAuthenticationArgs

ConnectorKafkaClusterClientAuthenticationType
, ConnectorKafkaClusterClientAuthenticationTypeArgs

ConnectorKafkaClusterEncryptionInTransit
, ConnectorKafkaClusterEncryptionInTransitArgs

ConnectorKafkaClusterEncryptionInTransitType
, ConnectorKafkaClusterEncryptionInTransitTypeArgs

ConnectorLogDelivery
, ConnectorLogDeliveryArgs

ConnectorPlugin
, ConnectorPluginArgs

ConnectorProvisionedCapacity
, ConnectorProvisionedCapacityArgs

ConnectorS3LogDelivery
, ConnectorS3LogDeliveryArgs

ConnectorScaleInPolicy
, ConnectorScaleInPolicyArgs

ConnectorScaleOutPolicy
, ConnectorScaleOutPolicyArgs

ConnectorVpc
, ConnectorVpcArgs

ConnectorWorkerConfiguration
, ConnectorWorkerConfigurationArgs

ConnectorWorkerLogDelivery
, ConnectorWorkerLogDeliveryArgs

Tag
, TagArgs