01README
Google Cloud managedkafka infrastructure models
02Models
@swamp/gcp/managedkafka/clustersv2026.04.23.1clusters.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| capacityConfig? | object | A capacity configuration of a Kafka cluster. |
| gcpConfig? | object | Configuration properties for a Kafka cluster deployed to Google Cloud Platform. |
| labels? | record | Optional. Labels as key value pairs. |
| name? | string | Identifier. The name of the cluster. Structured like: projects/{project_number}/locations/{location}/clusters/{cluster_id} |
| rebalanceConfig? | object | Defines rebalancing behavior of a Kafka cluster. |
| tlsConfig? | object | The TLS configuration for the Kafka cluster. |
| updateOptions? | object | UpdateOptions specifies options that influence how a cluster update is applied. These options control the behavior of the update process, rather than defining the desired end-state of a cluster. |
| clusterId? | string | Required. The ID to use for the cluster, which will become the final component of the cluster's name. The ID must be 1-63 characters long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is structured like: `my-cluster-id`. |
| requestId? | string | Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create(waitForReady?: boolean)
Create a clusters
| Argument | Type | Description |
|---|---|---|
| waitForReady? | boolean | Wait for the resource to reach a ready state after creation (default: true) |
fn get(identifier: string)
Get a clusters
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the clusters |
fn update(waitForReady?: boolean)
Update clusters attributes
| Argument | Type | Description |
|---|---|---|
| waitForReady? | boolean | Wait for the resource to reach a ready state after update (default: true) |
fn delete(identifier: string)
Delete the clusters
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the clusters |
fn sync()
Sync clusters state from GCP
Resources
state(infinite)— An Apache Kafka cluster deployed in a location.
@swamp/gcp/managedkafka/clusters-aclsv2026.04.23.1clusters_acls.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| aclEntries? | array | Required. The ACL entries that apply to the resource pattern. The maximum number of allowed entries 100. |
| name? | string | Identifier. The name for the acl. Represents a single Resource Pattern. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id} The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. `acl_id` is structured like one of the following: For acls on the cluster: `cluster` For acls on a single resource within the cluster: `topic/{resource_name}` `consumerGroup/{resource_name}` `transactionalId/{resource_name}` F |
| aclId? | string | Required. The ID to use for the acl, which will become the final component of the acl\ |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create()
Create a acls
fn get(identifier: string)
Get a acls
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the acls |
fn update()
Update acls attributes
fn delete(identifier: string)
Delete the acls
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the acls |
fn sync()
Sync acls state from GCP
fn add_acl_entry(host?: any, operation?: any, permissionType?: any, principal?: any)
add acl entry
| Argument | Type | Description |
|---|---|---|
| host? | any | |
| operation? | any | |
| permissionType? | any | |
| principal? | any |
Resources
state(infinite)— Represents the set of ACLs for a given Kafka Resource Pattern, which consists...
@swamp/gcp/managedkafka/clusters-consumergroupsv2026.04.23.1clusters_consumergroups.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name? | string | Identifier. The name of the consumer group. The `consumer_group` segment is used when connecting directly to the cluster. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumer_group} |
| topics? | record | Optional. Metadata for this consumer group for all topics it has metadata for. The key of the map is a topic name, structured like: projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic} |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a consumerGroups
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the consumerGroups |
fn update()
Update consumerGroups attributes
fn delete(identifier: string)
Delete the consumerGroups
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the consumerGroups |
fn sync()
Sync consumerGroups state from GCP
Resources
state(infinite)— A Kafka consumer group in a given cluster.
@swamp/gcp/managedkafka/clusters-topicsv2026.04.23.1clusters_topics.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| configs? | record | Optional. Configurations for the topic that are overridden from the cluster defaults. The key of the map is a Kafka topic property name, for example: `cleanup.policy`, `compression.type`. |
| name? | string | Identifier. The name of the topic. The `topic` segment is used when connecting directly to the cluster. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic} |
| partitionCount? | number | Required. The number of partitions this topic has. The partition count can only be increased, not decreased. Please note that if partitions are increased for a topic that has a key, the partitioning logic or the ordering of the messages will be affected. |
| replicationFactor? | number | Required. Immutable. The number of replicas of each partition. A replication factor of 3 is recommended for high availability. |
| topicId? | string | Required. The ID to use for the topic, which will become the final component of the topic's name. This value is structured like: `my-topic-name`. |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create()
Create a topics
fn get(identifier: string)
Get a topics
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the topics |
fn update()
Update topics attributes
fn delete(identifier: string)
Delete the topics
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the topics |
fn sync()
Sync topics state from GCP
Resources
state(infinite)— A Kafka topic in a given cluster.
@swamp/gcp/managedkafka/connectclustersv2026.04.23.1connectclusters.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| capacityConfig? | object | A capacity configuration of a Kafka cluster. |
| config? | record | Optional. Reserved for future use. This field is meant for worker config overrides, but is unsupported for now. |
| gcpConfig? | object | Configuration properties for a Kafka Connect cluster deployed to Google Cloud Platform. |
| kafkaCluster? | string | Required. Immutable. The name of the Kafka cluster this Kafka Connect cluster is attached to. Structured like: projects/{project}/locations/{location}/clusters/{cluster} |
| labels? | record | Optional. Labels as key value pairs. |
| name? | string | Identifier. The name of the Kafka Connect cluster. Structured like: projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id} |
| connectClusterId? | string | Required. The ID to use for the Connect cluster, which will become the final component of the cluster's name. The ID must be 1-63 characters long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is structured like: `my-cluster-id`. |
| requestId? | string | Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create(waitForReady?: boolean)
Create a connectClusters
| Argument | Type | Description |
|---|---|---|
| waitForReady? | boolean | Wait for the resource to reach a ready state after creation (default: true) |
fn get(identifier: string)
Get a connectClusters
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the connectClusters |
fn update(waitForReady?: boolean)
Update connectClusters attributes
| Argument | Type | Description |
|---|---|---|
| waitForReady? | boolean | Wait for the resource to reach a ready state after update (default: true) |
fn delete(identifier: string)
Delete the connectClusters
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the connectClusters |
fn sync()
Sync connectClusters state from GCP
Resources
state(infinite)— An Apache Kafka Connect cluster deployed in a location.
@swamp/gcp/managedkafka/connectclusters-connectorsv2026.04.23.1connectclusters_connectors.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| configs? | record | Optional. Connector config as keys/values. The keys of the map are connector property names, for example: `connector.class`, `tasks.max`, `key.converter`. |
| name? | string | Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector} |
| taskRestartPolicy? | object | Task Retry Policy is implemented on a best-effort basis. The default policy retries tasks with a minimum_backoff of 60 seconds, and a maximum_backoff of 12 hours. You can disable the policy by setting the task_retry_disabled field to true. Retry delay will be exponential based on provided minimum and maximum backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the delay between consecutive task restarts may not always precisely match the configured settings. This can happen whe |
| connectorId? | string | Required. The ID to use for the connector, which will become the final component of the connector's name. The ID must be 1-63 characters long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is structured like: `my-connector-id`. |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create(waitForReady?: boolean)
Create a connectors
| Argument | Type | Description |
|---|---|---|
| waitForReady? | boolean | Wait for the resource to reach a ready state after creation (default: true) |
fn get(identifier: string)
Get a connectors
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the connectors |
fn update(waitForReady?: boolean)
Update connectors attributes
| Argument | Type | Description |
|---|---|---|
| waitForReady? | boolean | Wait for the resource to reach a ready state after update (default: true) |
fn delete(identifier: string)
Delete the connectors
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the connectors |
fn sync()
Sync connectors state from GCP
fn pause()
pause
fn restart()
restart
fn resume()
resume
fn stop()
stop
Resources
state(infinite)— A Kafka Connect connector in a given ConnectCluster.
@swamp/gcp/managedkafka/locationsv2026.04.23.1locations.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
fn get(identifier: string)
Get a locations
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the locations |
fn sync()
Sync locations state from GCP
Resources
state(infinite)— A resource that represents a Google Cloud location.
@swamp/gcp/managedkafka/schemaregistriesv2026.04.23.1schemaregistries.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| schemaRegistry? | object | SchemaRegistry is a schema registry instance. |
| schemaRegistryId? | string | Required. The schema registry instance ID to use for this schema registry. The ID must contain only letters (a-z, A-Z), numbers (0-9), and underscores (-). The maximum length is 63 characters. The ID must not start with a number. |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create()
Create a schemaRegistries
fn get(identifier: string)
Get a schemaRegistries
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the schemaRegistries |
fn delete(identifier: string)
Delete the schemaRegistries
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the schemaRegistries |
fn sync()
Sync schemaRegistries state from GCP
Resources
state(infinite)— SchemaRegistry is a schema registry instance.
@swamp/gcp/managedkafka/schemaregistries-configv2026.04.23.1schemaregistries_config.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| compatibility? | enum | Required. The compatibility type of the schemas. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the compatibility field for the SchemaConfig. |
| normalize? | boolean | Optional. If true, the schema will be normalized before being stored or looked up. The default is false. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the normalize field for the SchemaConfig. |
fn get(identifier: string)
Get a config
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the config |
fn update()
Update config attributes
fn delete(identifier: string)
Delete the config
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the config |
fn sync()
Sync config state from GCP
Resources
state(infinite)— SchemaConfig represents configuration for a schema registry or a specific sub...
@swamp/gcp/managedkafka/schemaregistries-contextsv2026.04.23.1schemaregistries_contexts.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a contexts
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the contexts |
fn sync()
Sync contexts state from GCP
Resources
state(infinite)— Context represents an independent schema grouping in a schema registry instance.
@swamp/gcp/managedkafka/schemaregistries-contexts-configv2026.04.23.1schemaregistries_contexts_config.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| compatibility? | enum | Required. The compatibility type of the schemas. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the compatibility field for the SchemaConfig. |
| normalize? | boolean | Optional. If true, the schema will be normalized before being stored or looked up. The default is false. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the normalize field for the SchemaConfig. |
fn get(identifier: string)
Get a config
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the config |
fn update()
Update config attributes
fn delete(identifier: string)
Delete the config
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the config |
fn sync()
Sync config state from GCP
Resources
state(infinite)— SchemaConfig represents configuration for a schema registry or a specific sub...
@swamp/gcp/managedkafka/schemaregistries-contexts-modev2026.04.23.1schemaregistries_contexts_mode.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| mode? | enum | Required. The mode type. |
fn get(identifier: string)
Get a mode
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the mode |
fn update()
Update mode attributes
fn delete(identifier: string)
Delete the mode
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the mode |
fn sync()
Sync mode state from GCP
Resources
state(infinite)— SchemaMode represents the mode of a schema registry or a specific subject. Fo...
@swamp/gcp/managedkafka/schemaregistries-contexts-schemasv2026.04.23.1schemaregistries_contexts_schemas.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
fn get(identifier: string)
Get a schemas
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the schemas |
fn sync()
Sync schemas state from GCP
fn get_schema()
get schema
Resources
state(infinite)— Schema for a Kafka message.
@swamp/gcp/managedkafka/schemaregistries-contexts-schemas-subjectsv2026.04.23.1schemaregistries_contexts_schemas_subjects.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a subjects
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the subjects |
fn sync()
Sync subjects state from GCP
Resources
state(infinite)— List subjects which reference a particular schema id. The response will be an...
@swamp/gcp/managedkafka/schemaregistries-contexts-schemas-typesv2026.04.23.1schemaregistries_contexts_schemas_types.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a types
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the types |
fn sync()
Sync types state from GCP
Resources
state(infinite)— List the supported schema types. The response will be an array of schema types.
@swamp/gcp/managedkafka/schemaregistries-contexts-schemas-versionsv2026.04.23.1schemaregistries_contexts_schemas_versions.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a versions
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the versions |
fn sync()
Sync versions state from GCP
Resources
state(infinite)— List the schema versions for the given schema id. The response will be an arr...
@swamp/gcp/managedkafka/schemaregistries-contexts-subjectsv2026.04.23.1schemaregistries_contexts_subjects.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a subjects
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the subjects |
fn delete(identifier: string)
Delete the subjects
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the subjects |
fn sync()
Sync subjects state from GCP
fn lookup_version(deleted?: any, normalize?: any, references?: any, schema?: any, schemaType?: any)
lookup version
| Argument | Type | Description |
|---|---|---|
| deleted? | any | |
| normalize? | any | |
| references? | any | |
| schema? | any | |
| schemaType? | any |
Resources
state(infinite)— List subjects in the schema registry. The response will be an array of subjec...
@swamp/gcp/managedkafka/schemaregistries-contexts-subjects-versionsv2026.04.23.1schemaregistries_contexts_subjects_versions.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| id? | number | Optional. The schema ID of the schema. If not specified, the schema ID will be generated by the server. If the schema ID is specified, it must not be used by an existing schema that is different from the schema to be created. |
| normalize? | boolean | Optional. If true, the schema will be normalized before being stored. The default is false. |
| references? | array | Optional. The schema references used by the schema. |
| schema? | string | Required. The schema payload |
| schemaType? | enum | Optional. The type of the schema. It is optional. If not specified, the schema type will be AVRO. |
| version? | number | Optional. The version to create. It is optional. If not specified, the version will be created with the max version ID of the subject increased by 1. If the version ID is specified, it will be used as the new version ID and must not be used by an existing version of the subject. |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create()
Create a versions
fn get(identifier: string)
Get a versions
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the versions |
fn delete(identifier: string)
Delete the versions
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the versions |
fn sync()
Sync versions state from GCP
fn get_schema()
get schema
Resources
state(infinite)— Version of a schema.
@swamp/gcp/managedkafka/schemaregistries-contexts-subjects-versions-referencedbyv2026.04.23.1schemaregistries_contexts_subjects_versions_referencedby.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a referencedby
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the referencedby |
fn sync()
Sync referencedby state from GCP
Resources
state(infinite)— Get a list of IDs of schemas that reference the schema with the given subject...
@swamp/gcp/managedkafka/schemaregistries-modev2026.04.23.1schemaregistries_mode.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| mode? | enum | Required. The mode type. |
fn get(identifier: string)
Get a mode
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the mode |
fn update()
Update mode attributes
fn delete(identifier: string)
Delete the mode
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the mode |
fn sync()
Sync mode state from GCP
Resources
state(infinite)— SchemaMode represents the mode of a schema registry or a specific subject. Fo...
@swamp/gcp/managedkafka/schemaregistries-schemasv2026.04.23.1schemaregistries_schemas.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
fn get(identifier: string)
Get a schemas
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the schemas |
fn sync()
Sync schemas state from GCP
fn get_schema()
get schema
Resources
state(infinite)— Schema for a Kafka message.
@swamp/gcp/managedkafka/schemaregistries-schemas-subjectsv2026.04.23.1schemaregistries_schemas_subjects.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a subjects
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the subjects |
fn sync()
Sync subjects state from GCP
Resources
state(infinite)— List subjects which reference a particular schema id. The response will be an...
@swamp/gcp/managedkafka/schemaregistries-schemas-typesv2026.04.23.1schemaregistries_schemas_types.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a types
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the types |
fn sync()
Sync types state from GCP
Resources
state(infinite)— List the supported schema types. The response will be an array of schema types.
@swamp/gcp/managedkafka/schemaregistries-schemas-versionsv2026.04.23.1schemaregistries_schemas_versions.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a versions
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the versions |
fn sync()
Sync versions state from GCP
Resources
state(infinite)— List the schema versions for the given schema id. The response will be an arr...
@swamp/gcp/managedkafka/schemaregistries-subjectsv2026.04.23.1schemaregistries_subjects.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a subjects
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the subjects |
fn delete(identifier: string)
Delete the subjects
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the subjects |
fn sync()
Sync subjects state from GCP
fn lookup_version(deleted?: any, normalize?: any, references?: any, schema?: any, schemaType?: any)
lookup version
| Argument | Type | Description |
|---|---|---|
| deleted? | any | |
| normalize? | any | |
| references? | any | |
| schema? | any | |
| schemaType? | any |
Resources
state(infinite)— List subjects in the schema registry. The response will be an array of subjec...
@swamp/gcp/managedkafka/schemaregistries-subjects-versionsv2026.04.23.1schemaregistries_subjects_versions.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| id? | number | Optional. The schema ID of the schema. If not specified, the schema ID will be generated by the server. If the schema ID is specified, it must not be used by an existing schema that is different from the schema to be created. |
| normalize? | boolean | Optional. If true, the schema will be normalized before being stored. The default is false. |
| references? | array | Optional. The schema references used by the schema. |
| schema? | string | Required. The schema payload |
| schemaType? | enum | Optional. The type of the schema. It is optional. If not specified, the schema type will be AVRO. |
| version? | number | Optional. The version to create. It is optional. If not specified, the version will be created with the max version ID of the subject increased by 1. If the version ID is specified, it will be used as the new version ID and must not be used by an existing version of the subject. |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn create()
Create a versions
fn get(identifier: string)
Get a versions
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the versions |
fn delete(identifier: string)
Delete the versions
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the versions |
fn sync()
Sync versions state from GCP
fn get_schema()
get schema
Resources
state(infinite)— Version of a schema.
@swamp/gcp/managedkafka/schemaregistries-subjects-versions-referencedbyv2026.04.23.1schemaregistries_subjects_versions_referencedby.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| name | string | Instance name for this resource (used as the unique identifier in the factory pattern) |
| location? | string | The location for this resource (e.g., 'us', 'us-central1', 'europe-west1') |
fn get(identifier: string)
Get a referencedby
| Argument | Type | Description |
|---|---|---|
| identifier | string | The name of the referencedby |
fn sync()
Sync referencedby state from GCP
Resources
state(infinite)— Get a list of IDs of schemas that reference the schema with the given subject...
03Previous Versions
2026.04.19.1Apr 19, 2026
- Updated: connectclusters
2026.04.04.1Apr 4, 2026
- Updated: connectclusters
2026.04.03.3Apr 3, 2026
- Updated: locations, clusters, clusters_acls, clusters_consumergroups, clusters_topics, connectclusters, connectclusters_connectors, schemaregistries, schemaregistries_config, schemaregistries_contexts, schemaregistries_contexts_config, schemaregistries_contexts_mode, schemaregistries_contexts_schemas, schemaregistries_contexts_schemas_subjects, schemaregistries_contexts_schemas_types, schemaregistries_contexts_schemas_versions, schemaregistries_contexts_subjects, schemaregistries_contexts_subjects_versions, schemaregistries_contexts_subjects_versions_referencedby, schemaregistries_mode, schemaregistries_schemas, schemaregistries_schemas_subjects, schemaregistries_schemas_types, schemaregistries_schemas_versions, schemaregistries_subjects, schemaregistries_subjects_versions, schemaregistries_subjects_versions_referencedby
2026.04.03.1Apr 3, 2026
- Updated: locations, clusters, clusters_acls, clusters_consumergroups, clusters_topics, connectclusters, connectclusters_connectors, schemaregistries, schemaregistries_config, schemaregistries_contexts, schemaregistries_contexts_config, schemaregistries_contexts_mode, schemaregistries_contexts_schemas, schemaregistries_contexts_schemas_subjects, schemaregistries_contexts_schemas_types, schemaregistries_contexts_schemas_versions, schemaregistries_contexts_subjects, schemaregistries_contexts_subjects_versions, schemaregistries_contexts_subjects_versions_referencedby, schemaregistries_mode, schemaregistries_schemas, schemaregistries_schemas_subjects, schemaregistries_schemas_types, schemaregistries_schemas_versions, schemaregistries_subjects, schemaregistries_subjects_versions, schemaregistries_subjects_versions_referencedby
2026.04.02.2Apr 2, 2026
2026.03.27.1Mar 27, 2026
- Added: locations, clusters, clusters_acls, clusters_consumergroups, clusters_topics, connectclusters, connectclusters_connectors, schemaregistries, schemaregistries_config, schemaregistries_contexts, schemaregistries_contexts_config, schemaregistries_contexts_mode, schemaregistries_contexts_schemas, schemaregistries_contexts_schemas_subjects, schemaregistries_contexts_schemas_types, schemaregistries_contexts_schemas_versions, schemaregistries_contexts_subjects, schemaregistries_contexts_subjects_versions, schemaregistries_contexts_subjects_versions_referencedby, schemaregistries_mode, schemaregistries_schemas, schemaregistries_schemas_subjects, schemaregistries_schemas_types, schemaregistries_schemas_versions, schemaregistries_subjects, schemaregistries_subjects_versions, schemaregistries_subjects_versions_referencedby
04Stats
A
100 / 100
Downloads
0
Archive size
73.5 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 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