connector
Gets an individual connector
resource
Overview
Name | connector |
Type | Resource |
Description | connector |
Id | awscc.kafkaconnect.connector |
Fields
Name | Datatype | Description |
---|---|---|
capacity | object | |
connector_arn | string | Amazon Resource Name for the created Connector. |
connector_configuration | object | The configuration for the connector. |
connector_description | string | A summary description of the connector. |
connector_name | string | The name of the connector. |
kafka_cluster | object | |
kafka_cluster_client_authentication | object | |
kafka_cluster_encryption_in_transit | object | |
kafka_connect_version | string | The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins. |
log_delivery | object | |
plugins | array | List of plugins to use with the connector. |
service_execution_role_arn | string | The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources. |
worker_configuration | object | |
region | string | AWS region. |
Methods
Currently only SELECT
is supported for this resource resource.
Example
SELECT
region,
capacity,
connector_arn,
connector_configuration,
connector_description,
connector_name,
kafka_cluster,
kafka_cluster_client_authentication,
kafka_cluster_encryption_in_transit,
kafka_connect_version,
log_delivery,
plugins,
service_execution_role_arn,
worker_configuration
FROM awscc.kafkaconnect.connector
WHERE data__Identifier = '<ConnectorArn>';
Permissions
To operate on the connector
resource, the following permissions are required:
Read
kafkaconnect:DescribeConnector
Delete
kafkaconnect:DeleteConnector,
kafkaconnect:DescribeConnector,
logs:DeleteLogDelivery,
logs:GetLogDelivery,
logs:ListLogDeliveries
Update
kafkaconnect:UpdateConnector,
kafkaconnect:DescribeConnector,
iam:CreateServiceLinkedRole,
logs:UpdateLogDelivery,
logs:GetLogDelivery,
logs:ListLogDeliveries,
logs:PutResourcePolicy,
logs:DescribeResourcePolicies,
logs:DescribeLogGroups,
s3:GetBucketPolicy,
s3:PutBucketPolicy,
firehose:TagDeliveryStream