Package software.amazon.awscdk.cfnpropertymixins.services.kafkaconnect

Class CfnConnectorPropsMixin

java.lang.Object

software.amazon.jsii.JsiiObject

software.amazon.awscdk.Mixin

software.amazon.awscdk.cfnpropertymixins.services.kafkaconnect.CfnConnectorPropsMixin

All Implemented Interfaces:

software.amazon.jsii.JsiiSerializable, software.constructs.IMixin

@Generated(value="jsii-pacmak/1.127.0 (build 2117ad5)",
           date="2026-03-11T13:20:00.584Z")
@Stability(Stable)
public class CfnConnectorPropsMixin
extends Mixin
implements software.constructs.IMixin

Creates a connector using the specified properties.

Example:

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.cfnpropertymixins.services.kafkaconnect.*;
 import software.amazon.awscdk.*;
 IMergeStrategy mergeStrategy;
 CfnConnectorPropsMixin cfnConnectorPropsMixin = CfnConnectorPropsMixin.Builder.create(CfnConnectorMixinProps.builder()
         .capacity(CapacityProperty.builder()
                 .autoScaling(AutoScalingProperty.builder()
                         .maxAutoscalingTaskCount(123)
                         .maxWorkerCount(123)
                         .mcuCount(123)
                         .minWorkerCount(123)
                         .scaleInPolicy(ScaleInPolicyProperty.builder()
                                 .cpuUtilizationPercentage(123)
                                 .build())
                         .scaleOutPolicy(ScaleOutPolicyProperty.builder()
                                 .cpuUtilizationPercentage(123)
                                 .build())
                         .build())
                 .provisionedCapacity(ProvisionedCapacityProperty.builder()
                         .mcuCount(123)
                         .workerCount(123)
                         .build())
                 .build())
         .connectorConfiguration(Map.of(
                 "connectorConfigurationKey", "connectorConfiguration"))
         .connectorDescription("connectorDescription")
         .connectorName("connectorName")
         .kafkaCluster(KafkaClusterProperty.builder()
                 .apacheKafkaCluster(ApacheKafkaClusterProperty.builder()
                         .bootstrapServers("bootstrapServers")
                         .vpc(VpcProperty.builder()
                                 .securityGroups(List.of("securityGroups"))
                                 .subnets(List.of("subnets"))
                                 .build())
                         .build())
                 .build())
         .kafkaClusterClientAuthentication(KafkaClusterClientAuthenticationProperty.builder()
                 .authenticationType("authenticationType")
                 .build())
         .kafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransitProperty.builder()
                 .encryptionType("encryptionType")
                 .build())
         .kafkaConnectVersion("kafkaConnectVersion")
         .logDelivery(LogDeliveryProperty.builder()
                 .workerLogDelivery(WorkerLogDeliveryProperty.builder()
                         .cloudWatchLogs(CloudWatchLogsLogDeliveryProperty.builder()
                                 .enabled(false)
                                 .logGroup("logGroup")
                                 .build())
                         .firehose(FirehoseLogDeliveryProperty.builder()
                                 .deliveryStream("deliveryStream")
                                 .enabled(false)
                                 .build())
                         .s3(S3LogDeliveryProperty.builder()
                                 .bucket("bucket")
                                 .enabled(false)
                                 .prefix("prefix")
                                 .build())
                         .build())
                 .build())
         .networkType("networkType")
         .plugins(List.of(PluginProperty.builder()
                 .customPlugin(CustomPluginProperty.builder()
                         .customPluginArn("customPluginArn")
                         .revision(123)
                         .build())
                 .build()))
         .serviceExecutionRoleArn("serviceExecutionRoleArn")
         .tags(List.of(CfnTag.builder()
                 .key("key")
                 .value("value")
                 .build()))
         .workerConfiguration(WorkerConfigurationProperty.builder()
                 .revision(123)
                 .workerConfigurationArn("workerConfigurationArn")
                 .build())
         .build())
 .strategy(mergeStrategy)
 .build();
 

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CfnConnectorPropsMixin.ApacheKafkaClusterProperty	The details of the Apache Kafka cluster to which the connector is connected.
static interface	CfnConnectorPropsMixin.AutoScalingProperty	Specifies how the connector scales.
static final class	CfnConnectorPropsMixin.Builder	A fluent builder for CfnConnectorPropsMixin.
static interface	CfnConnectorPropsMixin.CapacityProperty	Information about the capacity of the connector, whether it is auto scaled or provisioned.
static interface	CfnConnectorPropsMixin.CloudWatchLogsLogDeliveryProperty	The settings for delivering connector logs to Amazon CloudWatch Logs.
static interface	CfnConnectorPropsMixin.CustomPluginProperty	A plugin is an AWS resource that contains the code that defines a connector's logic.
static interface	CfnConnectorPropsMixin.FirehoseLogDeliveryProperty	The settings for delivering logs to Amazon Kinesis Data Firehose.
static interface	CfnConnectorPropsMixin.KafkaClusterClientAuthenticationProperty	The client authentication information used in order to authenticate with the Apache Kafka cluster.
static interface	CfnConnectorPropsMixin.KafkaClusterEncryptionInTransitProperty	Details of encryption in transit to the Apache Kafka cluster.
static interface	CfnConnectorPropsMixin.KafkaClusterProperty	The details of the Apache Kafka cluster to which the connector is connected.
static interface	CfnConnectorPropsMixin.LogDeliveryProperty	Details about log delivery.
static interface	CfnConnectorPropsMixin.PluginProperty	A plugin is an AWS resource that contains the code that defines your connector logic.
static interface	CfnConnectorPropsMixin.ProvisionedCapacityProperty	Details about a connector's provisioned capacity.
static interface	CfnConnectorPropsMixin.S3LogDeliveryProperty	Details about delivering logs to Amazon S3.
static interface	CfnConnectorPropsMixin.ScaleInPolicyProperty	The scale-in policy for the connector.
static interface	CfnConnectorPropsMixin.ScaleOutPolicyProperty	The scale-out policy for the connector.
static interface	CfnConnectorPropsMixin.VpcProperty	Information about the VPC in which the connector resides.
static interface	CfnConnectorPropsMixin.WorkerConfigurationProperty	The configuration of the workers, which are the processes that run the connector logic.
static interface	CfnConnectorPropsMixin.WorkerLogDeliveryProperty	Workers can send worker logs to different destination types.

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.constructs.IMixin

software.constructs.IMixin.Jsii$Default, software.constructs.IMixin.Jsii$Proxy

Field Summary

Fields

Modifier and Type	Field	Description
protected static final List<String>	CFN_PROPERTY_KEYS

Constructor Summary

Constructors

Modifier	Constructor	Description
	CfnConnectorPropsMixin(CfnConnectorMixinProps props)	Create a mixin to apply properties to AWS::KafkaConnect::Connector.
	CfnConnectorPropsMixin(CfnConnectorMixinProps props, CfnPropertyMixinOptions options)	Create a mixin to apply properties to AWS::KafkaConnect::Connector.
protected	CfnConnectorPropsMixin(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	CfnConnectorPropsMixin(software.amazon.jsii.JsiiObjectRef objRef)

Method Summary

Modifier and Type	Method	Description
void	applyTo(software.constructs.IConstruct construct)	Apply the mixin properties to the construct.
protected CfnConnectorMixinProps	getProps()
protected IMergeStrategy	getStrategy()
Boolean	supports(software.constructs.IConstruct construct)	Check if this mixin supports the given construct.

Methods inherited from class software.amazon.awscdk.Mixin

isMixin

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Field Details

CFN_PROPERTY_KEYS

@Stability(Stable)
protected static final List<String> CFN_PROPERTY_KEYS

Constructor Details

CfnConnectorPropsMixin

protected CfnConnectorPropsMixin(software.amazon.jsii.JsiiObjectRef objRef)

CfnConnectorPropsMixin

protected CfnConnectorPropsMixin(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

CfnConnectorPropsMixin

@Stability(Stable)
public CfnConnectorPropsMixin(@NotNull
 CfnConnectorMixinProps props,
 @Nullable
 CfnPropertyMixinOptions options)

Create a mixin to apply properties to AWS::KafkaConnect::Connector.

Parameters:

props - L1 properties to apply. This parameter is required.

options - Mixin options.

CfnConnectorPropsMixin

@Stability(Stable)
public CfnConnectorPropsMixin(@NotNull
 CfnConnectorMixinProps props)

Create a mixin to apply properties to AWS::KafkaConnect::Connector.

Parameters:

props - L1 properties to apply. This parameter is required.

Method Details

applyTo

@Stability(Stable)
public void applyTo(@NotNull
 software.constructs.IConstruct construct)

Apply the mixin properties to the construct.

Specified by:

applyTo in interface software.constructs.IMixin

Specified by:

applyTo in class Mixin

Parameters:

construct - This parameter is required.

supports

@Stability(Stable)
@NotNull
public Boolean supports(@NotNull
 software.constructs.IConstruct construct)

Check if this mixin supports the given construct.

Specified by:

supports in interface software.constructs.IMixin

Overrides:

supports in class Mixin

Parameters:

construct - This parameter is required.

getProps

@Stability(Stable)
@NotNull
protected CfnConnectorMixinProps getProps()

getStrategy

@Stability(Stable)
@NotNull
protected IMergeStrategy getStrategy()