Skip to main content

connector

Gets an individual connector resource

Overview

Nameconnector
TypeResource
Descriptionconnector
Idawscc.kafkaconnect.connector

Fields

NameDatatypeDescription
capacityobject
connector_arnstringAmazon Resource Name for the created Connector.
connector_configurationobjectThe configuration for the connector.
connector_descriptionstringA summary description of the connector.
connector_namestringThe name of the connector.
kafka_clusterobject
kafka_cluster_client_authenticationobject
kafka_cluster_encryption_in_transitobject
kafka_connect_versionstringThe version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
log_deliveryobject
pluginsarrayList of plugins to use with the connector.
service_execution_role_arnstringThe Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
worker_configurationobject
regionstringAWS 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