package awskafkaconnect // Properties for defining a `CfnConnector`. // // Example: // // The code below shows an example of how to instantiate this type. // // The values are placeholders you should change. // import "github.com/aws/aws-cdk-go/awscdk" // // cfnConnectorProps := &CfnConnectorProps{ // Capacity: &CapacityProperty{ // AutoScaling: &AutoScalingProperty{ // MaxWorkerCount: jsii.Number(123), // McuCount: jsii.Number(123), // MinWorkerCount: jsii.Number(123), // ScaleInPolicy: &ScaleInPolicyProperty{ // CpuUtilizationPercentage: jsii.Number(123), // }, // ScaleOutPolicy: &ScaleOutPolicyProperty{ // CpuUtilizationPercentage: jsii.Number(123), // }, // }, // ProvisionedCapacity: &ProvisionedCapacityProperty{ // WorkerCount: jsii.Number(123), // // // the properties below are optional // McuCount: jsii.Number(123), // }, // }, // ConnectorConfiguration: map[string]*string{ // "connectorConfigurationKey": jsii.String("connectorConfiguration"), // }, // ConnectorName: jsii.String("connectorName"), // KafkaCluster: &KafkaClusterProperty{ // ApacheKafkaCluster: &ApacheKafkaClusterProperty{ // BootstrapServers: jsii.String("bootstrapServers"), // Vpc: &VpcProperty{ // SecurityGroups: []*string{ // jsii.String("securityGroups"), // }, // Subnets: []*string{ // jsii.String("subnets"), // }, // }, // }, // }, // KafkaClusterClientAuthentication: &KafkaClusterClientAuthenticationProperty{ // AuthenticationType: jsii.String("authenticationType"), // }, // KafkaClusterEncryptionInTransit: &KafkaClusterEncryptionInTransitProperty{ // EncryptionType: jsii.String("encryptionType"), // }, // KafkaConnectVersion: jsii.String("kafkaConnectVersion"), // Plugins: []interface{}{ // &PluginProperty{ // CustomPlugin: &CustomPluginProperty{ // CustomPluginArn: jsii.String("customPluginArn"), // Revision: jsii.Number(123), // }, // }, // }, // ServiceExecutionRoleArn: jsii.String("serviceExecutionRoleArn"), // // // the properties below are optional // ConnectorDescription: jsii.String("connectorDescription"), // LogDelivery: &LogDeliveryProperty{ // WorkerLogDelivery: &WorkerLogDeliveryProperty{ // CloudWatchLogs: &CloudWatchLogsLogDeliveryProperty{ // Enabled: jsii.Boolean(false), // // // the properties below are optional // LogGroup: jsii.String("logGroup"), // }, // Firehose: &FirehoseLogDeliveryProperty{ // Enabled: jsii.Boolean(false), // // // the properties below are optional // DeliveryStream: jsii.String("deliveryStream"), // }, // S3: &S3LogDeliveryProperty{ // Enabled: jsii.Boolean(false), // // // the properties below are optional // Bucket: jsii.String("bucket"), // Prefix: jsii.String("prefix"), // }, // }, // }, // WorkerConfiguration: &WorkerConfigurationProperty{ // Revision: jsii.Number(123), // WorkerConfigurationArn: jsii.String("workerConfigurationArn"), // }, // } // // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html // type CfnConnectorProps struct { // The connector's compute capacity settings. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-capacity // Capacity interface{} `field:"required" json:"capacity" yaml:"capacity"` // The configuration of the connector. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-connectorconfiguration // ConnectorConfiguration interface{} `field:"required" json:"connectorConfiguration" yaml:"connectorConfiguration"` // The name of the connector. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-connectorname // ConnectorName *string `field:"required" json:"connectorName" yaml:"connectorName"` // The details of the Apache Kafka cluster to which the connector is connected. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-kafkacluster // KafkaCluster interface{} `field:"required" json:"kafkaCluster" yaml:"kafkaCluster"` // The type of client authentication used to connect to the Apache Kafka cluster. // // The value is NONE when no client authentication is used. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-kafkaclusterclientauthentication // KafkaClusterClientAuthentication interface{} `field:"required" json:"kafkaClusterClientAuthentication" yaml:"kafkaClusterClientAuthentication"` // Details of encryption in transit to the Apache Kafka cluster. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-kafkaclusterencryptionintransit // KafkaClusterEncryptionInTransit interface{} `field:"required" json:"kafkaClusterEncryptionInTransit" yaml:"kafkaClusterEncryptionInTransit"` // The version of Kafka Connect. // // It has to be compatible with both the Apache Kafka cluster's version and the plugins. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-kafkaconnectversion // KafkaConnectVersion *string `field:"required" json:"kafkaConnectVersion" yaml:"kafkaConnectVersion"` // Specifies which plugin to use for the connector. // // You must specify a single-element list. Amazon MSK Connect does not currently support specifying multiple plugins. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-plugins // Plugins interface{} `field:"required" json:"plugins" yaml:"plugins"` // The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon Web Services resources. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-serviceexecutionrolearn // ServiceExecutionRoleArn *string `field:"required" json:"serviceExecutionRoleArn" yaml:"serviceExecutionRoleArn"` // The description of the connector. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-connectordescription // ConnectorDescription *string `field:"optional" json:"connectorDescription" yaml:"connectorDescription"` // The settings for delivering connector logs to Amazon CloudWatch Logs. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-logdelivery // LogDelivery interface{} `field:"optional" json:"logDelivery" yaml:"logDelivery"` // The worker configurations that are in use with the connector. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html#cfn-kafkaconnect-connector-workerconfiguration // WorkerConfiguration interface{} `field:"optional" json:"workerConfiguration" yaml:"workerConfiguration"` }