01README
AWS MSK infrastructure models
02Models
@swamp/aws/msk/batch-scram-secretv2026.04.23.2batch_scram_secret.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| ClusterArn | string | |
| SecretArnList? | array |
fn create()
Create a MSK BatchScramSecret
fn get(identifier: string)
Get a MSK BatchScramSecret
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK BatchScramSecret |
fn update()
Update a MSK BatchScramSecret
fn delete(identifier: string)
Delete a MSK BatchScramSecret
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK BatchScramSecret |
fn sync()
Sync MSK BatchScramSecret state from AWS
Resources
state(infinite)— MSK BatchScramSecret resource state
@swamp/aws/msk/clusterv2026.04.23.2cluster.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| BrokerNodeGroupInfo | object | |
| EnhancedMonitoring? | enum | |
| KafkaVersion | string | |
| NumberOfBrokerNodes | number | |
| EncryptionInfo? | object | |
| OpenMonitoring? | object | |
| ClusterName | string | |
| ClientAuthentication? | object | |
| LoggingInfo? | object | |
| Tags? | record | A key-value pair to associate with a resource. |
| ConfigurationInfo? | object | |
| StorageMode? | enum | |
| Rebalancing? | object |
fn create()
Create a MSK Cluster
fn get(identifier: string)
Get a MSK Cluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Cluster |
fn update()
Update a MSK Cluster
fn delete(identifier: string)
Delete a MSK Cluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Cluster |
fn sync()
Sync MSK Cluster state from AWS
Resources
state(infinite)— MSK Cluster resource state
@swamp/aws/msk/cluster-policyv2026.04.23.2cluster_policy.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| Policy | string | A policy document containing permissions to add to the specified cluster. |
| ClusterArn | string | The arn of the cluster for the resource policy. |
fn create()
Create a MSK ClusterPolicy
fn get(identifier: string)
Get a MSK ClusterPolicy
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ClusterPolicy |
fn update()
Update a MSK ClusterPolicy
fn delete(identifier: string)
Delete a MSK ClusterPolicy
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ClusterPolicy |
fn sync()
Sync MSK ClusterPolicy state from AWS
Resources
state(infinite)— MSK ClusterPolicy resource state
@swamp/aws/msk/configurationv2026.04.23.2configuration.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| Name | string | |
| ServerProperties | string | |
| KafkaVersionsList? | array |
fn create()
Create a MSK Configuration
fn get(identifier: string)
Get a MSK Configuration
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Configuration |
fn update()
Update a MSK Configuration
fn delete(identifier: string)
Delete a MSK Configuration
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Configuration |
fn sync()
Sync MSK Configuration state from AWS
Resources
state(infinite)— MSK Configuration resource state
@swamp/aws/msk/replicatorv2026.04.23.2replicator.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| ReplicatorName | string | The name of the replicator. |
| Description? | string | A summary description of the replicator. |
| KafkaClusters | array | Specifies a list of Kafka clusters which are targets of the replicator. |
| ReplicationInfoList | array | A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow. |
| ServiceExecutionRoleArn | string | The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources. |
| Tags? | array | A collection of tags associated with a resource |
| LogDelivery? | object | Configuration for log delivery for the replicator. |
fn create()
Create a MSK Replicator
fn get(identifier: string)
Get a MSK Replicator
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Replicator |
fn update()
Update a MSK Replicator
fn delete(identifier: string)
Delete a MSK Replicator
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Replicator |
fn sync()
Sync MSK Replicator state from AWS
Resources
state(infinite)— MSK Replicator resource state
@swamp/aws/msk/serverless-clusterv2026.04.23.2serverless_cluster.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| ClusterName | string | |
| VpcConfigs | array | |
| ClientAuthentication | object | |
| Tags? | record | A key-value pair to associate with a resource. |
fn create()
Create a MSK ServerlessCluster
fn get(identifier: string)
Get a MSK ServerlessCluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ServerlessCluster |
fn delete(identifier: string)
Delete a MSK ServerlessCluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ServerlessCluster |
fn sync()
Sync MSK ServerlessCluster state from AWS
Resources
state(infinite)— MSK ServerlessCluster resource state
@swamp/aws/msk/topicv2026.04.23.2topic.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| ClusterArn | string | The Amazon Resource Name (ARN) of the MSK cluster |
| TopicName | string | The name of the topic |
| PartitionCount | number | The number of partitions for the topic |
| ReplicationFactor | number | The replication factor for the topic |
| Configs? | string | Base64 encoded configuration properties of the topic |
fn create()
Create a MSK Topic
fn get(identifier: string)
Get a MSK Topic
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Topic |
fn update()
Update a MSK Topic
fn delete(identifier: string)
Delete a MSK Topic
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Topic |
fn sync()
Sync MSK Topic state from AWS
Resources
state(infinite)— MSK Topic resource state
@swamp/aws/msk/vpc-connectionv2026.04.23.2vpc_connection.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| Authentication | enum | The type of private link authentication |
| ClientSubnets | array | |
| TargetClusterArn | string | The Amazon Resource Name (ARN) of the target cluster |
| SecurityGroups | array | |
| Tags? | record | A key-value pair to associate with a resource. |
| VpcId | string |
fn create()
Create a MSK VpcConnection
fn get(identifier: string)
Get a MSK VpcConnection
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK VpcConnection |
fn update()
Update a MSK VpcConnection
fn delete(identifier: string)
Delete a MSK VpcConnection
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK VpcConnection |
fn sync()
Sync MSK VpcConnection state from AWS
Resources
state(infinite)— MSK VpcConnection resource state
03Previous Versions
2026.04.23.2Apr 23, 2026
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
2026.04.21.1Apr 21, 2026
- Updated: replicator
2026.04.03.2Apr 3, 2026
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
2026.03.19.1Mar 19, 2026
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
2026.03.16.1Mar 16, 2026
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
2026.03.10.5Mar 10, 2026
04Stats
A
100 / 100
Downloads
0
Archive size
1.5 MB
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 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
05Platforms
06Labels