Aws/kafkaconnect

@swamp/aws/kafkaconnectv2026.10.25.1· AGPL-3.0-or-later· 1d agoBEHAVIORS

01README

AWS KAFKACONNECT infrastructure models

02Behaviors3

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

Global Arguments

Argument	Type	Required	Description
name	string	yes	Instance name for this resource (used as the unique identifier in the factory pattern)
accessKeyId?	string	no	AWS access key ID; overrides AWS_ACCESS_KEY_ID environment variable. Wire with a vault.get(...) expression to source it from a vault.
secretAccessKey?	string	no	AWS secret access key; overrides AWS_SECRET_ACCESS_KEY environment variable. Wire with a vault.get(...) expression to source it from a vault.
sessionToken?	string	no	AWS session token for temporary credentials; overrides AWS_SESSION_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
region?	string	no	AWS region; overrides AWS_REGION / AWS_DEFAULT_REGION environment variables and ~/.aws/config profile region. Defaults to us-east-1.
Capacity	object	yes	Information about the capacity allocated to the connector.
ConnectorConfiguration	record	yes	The configuration for the connector.
ConnectorDescription?	string	no	A summary description of the connector.
ConnectorName	string	yes	The name of the connector.
KafkaCluster	object	yes	Details of how to connect to the Kafka cluster.
KafkaClusterClientAuthentication	object	yes	Details of the client authentication used by the Kafka cluster.
KafkaClusterEncryptionInTransit	object	yes	Details of encryption in transit to the Kafka cluster.
KafkaConnectVersion	string	yes	The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
NetworkType?	enum	no	The network type of the Connector.
LogDelivery?	object	no	Details of what logs are delivered and where they are delivered.
Plugins	array	yes	List of plugins to use with the connector.
ServiceExecutionRoleArn	string	yes	The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
Tags?	array	no	A collection of tags associated with a resource
WorkerConfiguration?	object	no	Specifies the worker configuration to use with the connector.

fn create()

Create a KafkaConnect Connector

fn get(identifier: string)

Get a KafkaConnect Connector

Argument	Type	Required	Description
identifier	string	yes	The primary identifier of the KafkaConnect Connector

fn update()

Update a KafkaConnect Connector

fn delete(identifier: string)

Delete a KafkaConnect Connector

Argument	Type	Required	Description
identifier	string	yes	The primary identifier of the KafkaConnect Connector

fn sync()

Sync KafkaConnect Connector state from AWS

fn list(maxPages?: number, resourceModel?: string)

List KafkaConnect Connector resources

Argument	Type	Required	Description
maxPages?	number	no	Maximum number of pages to fetch (default: 10)
resourceModel?	string	no	JSON resource model for parent-scoped listing (e.g. parent identifier)

Resources

state(infinite)— KafkaConnect Connector resource state

@swamp/aws/kafkaconnect/custom-pluginv2026.10.23.1custom_plugin.ts

Global Arguments

Argument	Type	Required	Description
name	string	yes	Instance name for this resource (used as the unique identifier in the factory pattern)
accessKeyId?	string	no	AWS access key ID; overrides AWS_ACCESS_KEY_ID environment variable. Wire with a vault.get(...) expression to source it from a vault.
secretAccessKey?	string	no	AWS secret access key; overrides AWS_SECRET_ACCESS_KEY environment variable. Wire with a vault.get(...) expression to source it from a vault.
sessionToken?	string	no	AWS session token for temporary credentials; overrides AWS_SESSION_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
region?	string	no	AWS region; overrides AWS_REGION / AWS_DEFAULT_REGION environment variables and ~/.aws/config profile region. Defaults to us-east-1.
Name	string	yes	The name of the custom plugin.
Description?	string	no	A summary description of the custom plugin.
ContentType	enum	yes	The type of the plugin file.
FileDescription?	object	no	Details about the custom plugin file.
Location	object	yes	Information about the location of a custom plugin.
Tags?	array	no	An array of key-value pairs to apply to this resource.

fn create()

Create a KafkaConnect CustomPlugin

fn get(identifier: string)

Get a KafkaConnect CustomPlugin

Argument	Type	Required	Description
identifier	string	yes	The primary identifier of the KafkaConnect CustomPlugin

fn update()

Update a KafkaConnect CustomPlugin

fn delete(identifier: string)

Delete a KafkaConnect CustomPlugin

Argument	Type	Required	Description
identifier	string	yes	The primary identifier of the KafkaConnect CustomPlugin

fn sync()

Sync KafkaConnect CustomPlugin state from AWS

fn list(maxPages?: number, resourceModel?: string)

List KafkaConnect CustomPlugin resources

Argument	Type	Required	Description
maxPages?	number	no	Maximum number of pages to fetch (default: 10)
resourceModel?	string	no	JSON resource model for parent-scoped listing (e.g. parent identifier)

Resources

state(infinite)— KafkaConnect CustomPlugin resource state

@swamp/aws/kafkaconnect/worker-configurationv2026.10.23.1worker_configuration.ts

Global Arguments

Argument	Type	Required	Description
name	string	yes	Instance name for this resource (used as the unique identifier in the factory pattern)
accessKeyId?	string	no	AWS access key ID; overrides AWS_ACCESS_KEY_ID environment variable. Wire with a vault.get(...) expression to source it from a vault.
secretAccessKey?	string	no	AWS secret access key; overrides AWS_SECRET_ACCESS_KEY environment variable. Wire with a vault.get(...) expression to source it from a vault.
sessionToken?	string	no	AWS session token for temporary credentials; overrides AWS_SESSION_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
region?	string	no	AWS region; overrides AWS_REGION / AWS_DEFAULT_REGION environment variables and ~/.aws/config profile region. Defaults to us-east-1.
Name	string	yes	The name of the worker configuration.
Description?	string	no	A summary description of the worker configuration.
PropertiesFileContent	string	yes	Base64 encoded contents of connect-distributed.properties file.
Tags?	array	no	A collection of tags associated with a resource

fn create()

Create a KafkaConnect WorkerConfiguration

fn get(identifier: string)

Get a KafkaConnect WorkerConfiguration

Argument	Type	Required	Description
identifier	string	yes	The primary identifier of the KafkaConnect WorkerConfiguration

fn update()

Update a KafkaConnect WorkerConfiguration

fn delete(identifier: string)

Delete a KafkaConnect WorkerConfiguration

Argument	Type	Required	Description
identifier	string	yes	The primary identifier of the KafkaConnect WorkerConfiguration

fn sync()

Sync KafkaConnect WorkerConfiguration state from AWS

fn list(maxPages?: number, resourceModel?: string)

List KafkaConnect WorkerConfiguration resources

Argument	Type	Required	Description
maxPages?	number	no	Maximum number of pages to fetch (default: 10)
resourceModel?	string	no	JSON resource model for parent-scoped listing (e.g. parent identifier)

Resources

state(infinite)— KafkaConnect WorkerConfiguration resource state

03Previous Versions19

2026.10.24.1AGPL-3.0-or-laterOct 24, 2026

2026.10.23.1AGPL-3.0-or-later(was none)Oct 24, 2026

Updated: connector, custom_plugin, worker_configuration

2026.10.13.1Oct 13, 2026

Updated: connector, custom_plugin, worker_configuration

2026.10.08.1Oct 8, 2026

2026.10.06.1Oct 6, 2026

2026.10.04.1Oct 4, 2026

2026.10.03.1Oct 3, 2026

2026.10.02.1Oct 2, 2026

2026.10.01.1Oct 1, 2026

2026.09.30.1Sep 30, 2026

2026.09.29.1Sep 29, 2026

2026.09.28.1Sep 28, 2026

2026.09.27.1Sep 27, 2026

2026.09.26.1Sep 26, 2026

2026.09.25.1Sep 25, 2026

2026.09.24.1Sep 24, 2026

2026.09.23.1Sep 23, 2026

2026.09.22.1Sep 22, 2026

2026.09.21.1Sep 21, 2026

04Stats

100 / 100

Downloads

115

Archive size

623.9 KB

Verified by Swamp

Has README or module doc2/2earned
README has a code example1/1earned
README is substantive1/1earned
Most symbols documented1/1earned
No slow types (deprecated)1/1earned
Dependencies pass trust audit2/2earned
Docs keep secrets in a vault1/1earned
Has description1/1earned
Platform support declared (or universal)2/2earned
License2/2earned
Verified public repository2/2earned

Repository

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

05Platforms

linux · x86_64 linux · aarch64 macOS · x86_64 macOS · aarch64 windows · x86_64

06Labels

#aws #kafkaconnect #cloud #infrastructure