pulumi-aws-native-kotlin/com.pulumi.awsnative.kafkaconnect.kotlin.outputs

Package-level declarations

Types

data class ConnectorApacheKafkaCluster(val bootstrapServers: String, val vpc: ConnectorVpc)

Details of how to connect to an Apache Kafka cluster.

data class ConnectorAutoScaling(val maxWorkerCount: Int, val mcuCount: Int, val minWorkerCount: Int, val scaleInPolicy: ConnectorScaleInPolicy, val scaleOutPolicy: ConnectorScaleOutPolicy)

Details about auto scaling of a connector.

ConnectorCapacity

data class ConnectorCapacity(val autoScaling: ConnectorAutoScaling? = null, val provisionedCapacity: ConnectorProvisionedCapacity? = null)

Information about the capacity allocated to the connector.

ConnectorCloudWatchLogsLogDelivery

data class ConnectorCloudWatchLogsLogDelivery(val enabled: Boolean, val logGroup: String? = null)

Details about delivering logs to Amazon CloudWatch Logs.

ConnectorCustomPlugin

data class ConnectorCustomPlugin(val customPluginArn: String, val revision: Int)

Details about a custom plugin.

ConnectorFirehoseLogDelivery

data class ConnectorFirehoseLogDelivery(val deliveryStream: String? = null, val enabled: Boolean)

Details about delivering logs to Amazon Kinesis Data Firehose.

ConnectorKafkaCluster

data class ConnectorKafkaCluster(val apacheKafkaCluster: ConnectorApacheKafkaCluster)

Details of how to connect to the Kafka cluster.

ConnectorKafkaClusterClientAuthentication

data class ConnectorKafkaClusterClientAuthentication(val authenticationType: ConnectorKafkaClusterClientAuthenticationType)

Details of the client authentication used by the Kafka cluster.

ConnectorKafkaClusterEncryptionInTransit

data class ConnectorKafkaClusterEncryptionInTransit(val encryptionType: ConnectorKafkaClusterEncryptionInTransitType)

Details of encryption in transit to the Kafka cluster.

ConnectorLogDelivery

data class ConnectorLogDelivery(val workerLogDelivery: ConnectorWorkerLogDelivery)

Details of what logs are delivered and where they are delivered.

ConnectorPlugin

data class ConnectorPlugin(val customPlugin: ConnectorCustomPlugin)

Details about a Kafka Connect plugin which will be used with the connector.

ConnectorProvisionedCapacity

data class ConnectorProvisionedCapacity(val mcuCount: Int? = null, val workerCount: Int)

Details about a fixed capacity allocated to a connector.

ConnectorS3LogDelivery

data class ConnectorS3LogDelivery(val bucket: String? = null, val enabled: Boolean, val prefix: String? = null)

Details about delivering logs to Amazon S3.

ConnectorScaleInPolicy

data class ConnectorScaleInPolicy(val cpuUtilizationPercentage: Int)

Information about the scale in policy of the connector.

ConnectorScaleOutPolicy

data class ConnectorScaleOutPolicy(val cpuUtilizationPercentage: Int)

Information about the scale out policy of the connector.

ConnectorVpc

data class ConnectorVpc(val securityGroups: List<String>, val subnets: List<String>)

Information about a VPC used with the connector.

ConnectorWorkerConfiguration

data class ConnectorWorkerConfiguration(val revision: Int, val workerConfigurationArn: String)

Specifies the worker configuration to use with the connector.

ConnectorWorkerLogDelivery

data class ConnectorWorkerLogDelivery(val cloudWatchLogs: ConnectorCloudWatchLogsLogDelivery? = null, val firehose: ConnectorFirehoseLogDelivery? = null, val s3: ConnectorS3LogDelivery? = null)

Specifies where worker logs are delivered.

CustomPluginFileDescription

data class CustomPluginFileDescription(val fileMd5: String? = null, val fileSize: Int? = null)

Details about the custom plugin file.

CustomPluginLocation

data class CustomPluginLocation(val s3Location: CustomPluginS3Location)

Information about the location of a custom plugin.

CustomPluginS3Location

data class CustomPluginS3Location(val bucketArn: String, val fileKey: String, val objectVersion: String? = null)

The S3 bucket Amazon Resource Name (ARN), file key, and object version of the plugin file stored in Amazon S3.

GetConnectorResult

data class GetConnectorResult(val capacity: ConnectorCapacity? = null, val connectorArn: String? = null, val tags: List<Tag>? = null)

GetCustomPluginResult

data class GetCustomPluginResult(val customPluginArn: String? = null, val fileDescription: CustomPluginFileDescription? = null, val revision: Int? = null, val tags: List<Tag>? = null)

GetWorkerConfigurationResult

data class GetWorkerConfigurationResult(val revision: Int? = null, val tags: List<Tag>? = null, val workerConfigurationArn: String? = null)