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