@swamp/aws/msk
v2026.04.23.3
AWS MSK infrastructure models
Repository
https://github.com/systeminit/swamp-extensions
Labels
awsmskcloudinfrastructure
Contents
Quality score
Verified by SwampHow well-documented and verifiable this extension is.
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/msk@swamp/aws/msk/batch-scram-secretv2026.04.23.2batch_scram_secret.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| ClusterArn | string | |
| SecretArnList? | array |
createCreate a MSK BatchScramSecret
getGet a MSK BatchScramSecret
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK BatchScramSecret |
updateUpdate a MSK BatchScramSecret
deleteDelete a MSK BatchScramSecret
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK BatchScramSecret |
syncSync 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 |
createCreate a MSK Cluster
getGet a MSK Cluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Cluster |
updateUpdate a MSK Cluster
deleteDelete a MSK Cluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Cluster |
syncSync 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. |
createCreate a MSK ClusterPolicy
getGet a MSK ClusterPolicy
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ClusterPolicy |
updateUpdate a MSK ClusterPolicy
deleteDelete a MSK ClusterPolicy
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ClusterPolicy |
syncSync 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 |
createCreate a MSK Configuration
getGet a MSK Configuration
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Configuration |
updateUpdate a MSK Configuration
deleteDelete a MSK Configuration
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Configuration |
syncSync 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. |
createCreate a MSK Replicator
getGet a MSK Replicator
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Replicator |
updateUpdate a MSK Replicator
deleteDelete a MSK Replicator
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Replicator |
syncSync 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. |
createCreate a MSK ServerlessCluster
getGet a MSK ServerlessCluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ServerlessCluster |
deleteDelete a MSK ServerlessCluster
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK ServerlessCluster |
syncSync 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 |
createCreate a MSK Topic
getGet a MSK Topic
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Topic |
updateUpdate a MSK Topic
deleteDelete a MSK Topic
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK Topic |
syncSync 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 |
createCreate a MSK VpcConnection
getGet a MSK VpcConnection
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK VpcConnection |
updateUpdate a MSK VpcConnection
deleteDelete a MSK VpcConnection
| Argument | Type | Description |
|---|---|---|
| identifier | string | The primary identifier of the MSK VpcConnection |
syncSync MSK VpcConnection state from AWS
Resources
state(infinite)— MSK VpcConnection resource state
2026.04.23.21.5 MBApr 23, 2026
AWS MSK infrastructure models
Release Notes
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
linux-x86_64linux-aarch64darwin-x86_64darwin-aarch64
awsmskcloudinfrastructure
2026.04.21.11.5 MBApr 21, 2026
AWS MSK infrastructure models
Release Notes
- Updated: replicator
linux-x86_64linux-aarch64darwin-x86_64darwin-aarch64
awsmskcloudinfrastructure
2026.04.03.21.5 MBApr 3, 2026
AWS MSK infrastructure models
Release Notes
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
linux-x86_64linux-aarch64darwin-x86_64darwin-aarch64
awsmskcloudinfrastructure
2026.03.19.11.6 MBMar 19, 2026
AWS MSK infrastructure models
Release Notes
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
linux-x86_64linux-aarch64darwin-x86_64darwin-aarch64
awsmskcloudinfrastructure
2026.03.16.11.6 MBMar 16, 2026
AWS MSK infrastructure models
Release Notes
- Updated: batch_scram_secret, cluster, cluster_policy, configuration, replicator, serverless_cluster, topic, vpc_connection
linux-x86_64linux-aarch64darwin-x86_64darwin-aarch64
awsmskcloudinfrastructure
2026.03.10.51.6 MBMar 10, 2026
AWS MSK infrastructure models
linux-x86_64linux-aarch64darwin-x86_64darwin-aarch64
awsmskcloudinfrastructure