class Aws::KafkaConnect::Types::CreateConnectorRequest

@note When making an API call, you may pass CreateConnectorRequest

data as a hash:

    {
      capacity: { # required
        auto_scaling: {
          max_worker_count: 1, # required
          mcu_count: 1, # required
          min_worker_count: 1, # required
          scale_in_policy: {
            cpu_utilization_percentage: 1, # required
          },
          scale_out_policy: {
            cpu_utilization_percentage: 1, # required
          },
        },
        provisioned_capacity: {
          mcu_count: 1, # required
          worker_count: 1, # required
        },
      },
      connector_configuration: { # required
        "__string" => "__string",
      },
      connector_description: "__stringMax1024",
      connector_name: "__stringMin1Max128", # required
      kafka_cluster: { # required
        apache_kafka_cluster: { # required
          bootstrap_servers: "__string", # required
          vpc: { # required
            security_groups: ["__string"],
            subnets: ["__string"], # required
          },
        },
      },
      kafka_cluster_client_authentication: { # required
        authentication_type: "NONE", # required, accepts NONE, IAM
      },
      kafka_cluster_encryption_in_transit: { # required
        encryption_type: "PLAINTEXT", # required, accepts PLAINTEXT, TLS
      },
      kafka_connect_version: "__string", # required
      log_delivery: {
        worker_log_delivery: { # required
          cloud_watch_logs: {
            enabled: false, # required
            log_group: "__string",
          },
          firehose: {
            delivery_stream: "__string",
            enabled: false, # required
          },
          s3: {
            bucket: "__string",
            enabled: false, # required
            prefix: "__string",
          },
        },
      },
      plugins: [ # required
        {
          custom_plugin: { # required
            custom_plugin_arn: "__string", # required
            revision: 1, # required
          },
        },
      ],
      service_execution_role_arn: "__string", # required
      worker_configuration: {
        revision: 1, # required
        worker_configuration_arn: "__string", # required
      },
    }

@!attribute [rw] capacity

Information about the capacity allocated to the connector. Exactly
one of the two properties must be specified.
@return [Types::Capacity]

@!attribute [rw] connector_configuration

A map of keys to values that represent the configuration for the
connector.
@return [Hash<String,String>]

@!attribute [rw] connector_description

A summary description of the connector.
@return [String]

@!attribute [rw] connector_name

The name of the connector.
@return [String]

@!attribute [rw] kafka_cluster

Specifies which Apache Kafka cluster to connect to.
@return [Types::KafkaCluster]

@!attribute [rw] kafka_cluster_client_authentication

Details of the client authentication used by the Apache Kafka
cluster.
@return [Types::KafkaClusterClientAuthentication]

@!attribute [rw] kafka_cluster_encryption_in_transit

Details of encryption in transit to the Apache Kafka cluster.
@return [Types::KafkaClusterEncryptionInTransit]

@!attribute [rw] kafka_connect_version

The version of Kafka Connect. It has to be compatible with both the
Apache Kafka cluster's version and the plugins.
@return [String]

@!attribute [rw] log_delivery

Details about log delivery.
@return [Types::LogDelivery]

@!attribute [rw] plugins

Specifies which plugins to use for the connector.
@return [Array<Types::Plugin>]

@!attribute [rw] service_execution_role_arn

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.
@return [String]

@!attribute [rw] worker_configuration

Specifies which worker configuration to use with the connector.
@return [Types::WorkerConfiguration]

@see docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateConnectorRequest AWS API Documentation

Constants

SENSITIVE