Skip to main content

@swamp/aws/kafkaconnect

v2026.04.23.3

AWS KAFKACONNECT infrastructure models

Repository

https://github.com/systeminit/swamp-extensions

Labels

awskafkaconnectcloudinfrastructure

Contents

Quality score

Verified by Swamp

How well-documented and verifiable this extension is.

100%

Grade A

  • Has README or module doc2/2earned
  • README has a code example1/1earned
  • README is substantive1/1earned
  • Most symbols documented1/1earned
  • No slow types1/1earned
  • Has description1/1earned
  • At least one platform tag (or universal)1/1earned
  • Two or more platform tags (or universal)1/1earned
  • License declared1/1earned
  • Verified public repository2/2earned

Install

$ swamp extension pull @swamp/aws/kafkaconnect

@swamp/aws/kafkaconnect/connectorv2026.04.23.2connector.ts

Global Arguments

ArgumentTypeDescription
namestringInstance name for this resource (used as the unique identifier in the factory pattern)
CapacityobjectInformation about the capacity allocated to the connector.
ConnectorConfigurationrecordThe configuration for the connector.
ConnectorDescription?stringA summary description of the connector.
ConnectorNamestringThe name of the connector.
KafkaClusterobjectDetails of how to connect to the Kafka cluster.
KafkaClusterClientAuthenticationobjectDetails of the client authentication used by the Kafka cluster.
KafkaClusterEncryptionInTransitobjectDetails of encryption in transit to the Kafka cluster.
KafkaConnectVersionstringThe version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
NetworkType?enumThe network type of the Connector.
LogDelivery?objectDetails of what logs are delivered and where they are delivered.
PluginsarrayList of plugins to use with the connector.
ServiceExecutionRoleArnstringThe Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
Tags?arrayA collection of tags associated with a resource
WorkerConfiguration?objectSpecifies the worker configuration to use with the connector.
createCreate a KafkaConnect Connector
getGet a KafkaConnect Connector
ArgumentTypeDescription
identifierstringThe primary identifier of the KafkaConnect Connector
updateUpdate a KafkaConnect Connector
deleteDelete a KafkaConnect Connector
ArgumentTypeDescription
identifierstringThe primary identifier of the KafkaConnect Connector
syncSync KafkaConnect Connector state from AWS

Resources

state(infinite)— KafkaConnect Connector resource state
@swamp/aws/kafkaconnect/custom-pluginv2026.04.23.2custom_plugin.ts

Global Arguments

ArgumentTypeDescription
namestringInstance name for this resource (used as the unique identifier in the factory pattern)
NamestringThe name of the custom plugin.
Description?stringA summary description of the custom plugin.
ContentTypeenumThe type of the plugin file.
FileDescription?objectDetails about the custom plugin file.
LocationobjectInformation about the location of a custom plugin.
Tags?arrayAn array of key-value pairs to apply to this resource.
createCreate a KafkaConnect CustomPlugin
getGet a KafkaConnect CustomPlugin
ArgumentTypeDescription
identifierstringThe primary identifier of the KafkaConnect CustomPlugin
updateUpdate a KafkaConnect CustomPlugin
deleteDelete a KafkaConnect CustomPlugin
ArgumentTypeDescription
identifierstringThe primary identifier of the KafkaConnect CustomPlugin
syncSync KafkaConnect CustomPlugin state from AWS

Resources

state(infinite)— KafkaConnect CustomPlugin resource state
@swamp/aws/kafkaconnect/worker-configurationv2026.04.23.2worker_configuration.ts

Global Arguments

ArgumentTypeDescription
namestringInstance name for this resource (used as the unique identifier in the factory pattern)
NamestringThe name of the worker configuration.
Description?stringA summary description of the worker configuration.
PropertiesFileContentstringBase64 encoded contents of connect-distributed.properties file.
Tags?arrayA collection of tags associated with a resource
createCreate a KafkaConnect WorkerConfiguration
getGet a KafkaConnect WorkerConfiguration
ArgumentTypeDescription
identifierstringThe primary identifier of the KafkaConnect WorkerConfiguration
updateUpdate a KafkaConnect WorkerConfiguration
deleteDelete a KafkaConnect WorkerConfiguration
ArgumentTypeDescription
identifierstringThe primary identifier of the KafkaConnect WorkerConfiguration
syncSync KafkaConnect WorkerConfiguration state from AWS

Resources

state(infinite)— KafkaConnect WorkerConfiguration resource state