Confluent Associations API
The Associations API from Confluent — 4 operation(s) for associations.
Work with this as data
Every API here is available over the APIs.io API and to AI agents over MCP.
MCP server
One button, every client — Claude, Cursor, VS Code and the rest.
https://apis.io/mcp
Tools for apis
7 MCP tools reach this
find_apisBrowse and filter every API in the catalog.get_api_artifactsOne API's artifacts, grouped by type.get_openapiThe primary OpenAPI for this API.find_similar_apisAPIs that look like this one.apis_io_searchSTART HERE — APIs, providers and tags for one query, each with its total.resolveTurn a domain, URL or GitHub org into the provider it belongs to.find_cohortsEvery scored population of providers in the catalog.
Call it yourself
curl for this page
This API
curl "https://apis.io/api/v1/apis/confluent-associations-api"
All apis
curl "https://apis.io/api/v1/apis?limit=25"Discovery needs no key. Ratings and market analysis are Pro.
Get an API key
Free tier, no form to fill in. Signing in shares your email address with us — we store it to create your key and to recognise you if you sign in with another provider. See our Privacy Policy and Terms.
A second provider on the same verified email joins the account you already have.
OpenAPI Specification
openapi: 3.2.0
info:
title: Confluent Associations API
version: v1
description: 'Operations tagged Associations across 2 of this provider''s published API definitions: schema-registry-api-spec.yaml, schema-registry-openapi.yaml. Each path carries the servers of the definition it was published in.'
tags:
- name: Associations
paths:
/associations:
post:
summary: Create an association
operationId: createAssociation
parameters:
- name: context
in: query
description: Context
schema:
type: string
- name: dryRun
in: query
description: Dry run
schema:
type: boolean
requestBody:
description: The create request
content:
application/vnd.schemaregistry.v1+json:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
application/vnd.schemaregistry+json:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
application/json:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
application/octet-stream:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
required: true
responses:
'200':
description: The create response
content:
application/vnd.schemaregistry.v1+json:
schema:
$ref: '#/components/schemas/AssociationResponse'
application/vnd.schemaregistry+json; qs=0.9:
schema:
$ref: '#/components/schemas/AssociationResponse'
application/json; qs=0.5:
schema:
$ref: '#/components/schemas/AssociationResponse'
'409':
description: Conflict. Error code 40911 -- Association already exists. Error code 40912 -- Too many associations.
'422':
description: Error code 42212 -- Invalid association
tags:
- Associations
/associations/resources/{resourceId}:
get:
summary: Get a list of associations by resource ID
operationId: getAssociationsByResourceId
parameters:
- name: resourceId
in: path
description: Resource ID
required: true
schema:
type: string
- name: resourceType
in: query
description: Resource type
schema:
type: string
- name: associationType
in: query
description: Association type
schema:
type: array
items:
type: string
- name: lifecycle
in: query
description: Lifecycle
schema:
type: string
enum:
- STRONG
- WEAK
- name: offset
in: query
description: Pagination offset for results
schema:
type: integer
format: int32
default: 0
- name: limit
in: query
description: Pagination size for results. Ignored if negative
schema:
type: integer
format: int32
default: -1
responses:
'200':
description: List of associations
content:
application/vnd.schemaregistry.v1+json:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
application/vnd.schemaregistry+json; qs=0.9:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
application/json; qs=0.5:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
tags:
- Associations
put:
summary: Create or update an association
operationId: createOrUpdateAssociation
parameters:
- name: resourceId
in: path
description: Resource ID
required: true
schema:
type: string
- name: context
in: query
description: Context
schema:
type: string
- name: dryRun
in: query
description: Dry run
schema:
type: boolean
requestBody:
description: The create or update request
content:
application/vnd.schemaregistry.v1+json:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
application/vnd.schemaregistry+json:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
application/json:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
application/octet-stream:
schema:
$ref: '#/components/schemas/AssociationCreateOrUpdateRequest'
required: true
responses:
'200':
description: The create or update response
content:
application/vnd.schemaregistry.v1+json:
schema:
$ref: '#/components/schemas/AssociationResponse'
application/vnd.schemaregistry+json; qs=0.9:
schema:
$ref: '#/components/schemas/AssociationResponse'
application/json; qs=0.5:
schema:
$ref: '#/components/schemas/AssociationResponse'
'409':
description: Conflict. Error code 40911 -- Association already exists. Error code 40912 -- Too many associations.
'422':
description: Error code 42212 -- Invalid association
tags:
- Associations
delete:
summary: Delete associations
operationId: deleteAssociations
parameters:
- name: resourceId
in: path
description: Resource ID
required: true
schema:
type: string
- name: resourceType
in: query
description: Resource type
schema:
type: string
- name: associationType
in: query
description: Association type
schema:
type: array
items:
type: string
- name: cascadeLifecycle
in: query
description: Cascade lifecycle
schema:
type: boolean
- name: dryRun
in: query
description: Dry run
schema:
type: boolean
- name: async
in: query
description: Delete the associations, return 202, and finish cascaded subject deletes in the background. 202 is returned even if no subject needed deleting. A queued subject is deleted even if new versions are registered under it before the background delete runs. Until then the subject still exists, so recreating the resource with a different schema can fail.
schema:
type: boolean
responses:
'204':
description: The associations, and any cascaded subjects, were deleted
'202':
description: The associations were deleted; cascaded subject deletes are running in the background (async=true only)
'404':
description: No associations found for the resource
'409':
description: The association is frozen and cascadeLifecycle is false
'422':
description: Error code 42212 -- Invalid association
tags:
- Associations
/associations/resources/{resourceNamespace}/{resourceName}:
get:
summary: Get a list of associations by resource name
operationId: getAssociationsByResourceName
parameters:
- name: resourceName
in: path
description: Resource name
required: true
schema:
type: string
- name: resourceNamespace
in: path
description: Resource namespace
required: true
schema:
type: string
- name: resourceType
in: query
description: Resource type
schema:
type: string
- name: associationType
in: query
description: Association type
schema:
type: array
items:
type: string
- name: lifecycle
in: query
description: Lifecycle
schema:
type: string
enum:
- STRONG
- WEAK
- name: offset
in: query
description: Pagination offset for results
schema:
type: integer
format: int32
default: 0
- name: limit
in: query
description: Pagination size for results. Ignored if negative
schema:
type: integer
format: int32
default: -1
responses:
'200':
description: List of associations
content:
application/vnd.schemaregistry.v1+json:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
application/vnd.schemaregistry+json; qs=0.9:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
application/json; qs=0.5:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
tags:
- Associations
/associations/subjects/{subject}:
get:
summary: Get a list of associations by subject
operationId: getAssociationsBySubject
parameters:
- name: subject
in: path
description: Subject
required: true
schema:
type: string
- name: resourceType
in: query
description: Resource type
schema:
type: string
- name: associationType
in: query
description: Association type
schema:
type: array
items:
type: string
- name: lifecycle
in: query
description: Lifecycle
schema:
type: string
enum:
- STRONG
- WEAK
- name: offset
in: query
description: Pagination offset for results
schema:
type: integer
format: int32
default: 0
- name: limit
in: query
description: Pagination size for results. Ignored if negative
schema:
type: integer
format: int32
default: -1
responses:
'200':
description: List of associations
content:
application/vnd.schemaregistry.v1+json:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
application/vnd.schemaregistry+json; qs=0.9:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
application/json; qs=0.5:
schema:
type: array
items:
$ref: '#/components/schemas/Association'
tags:
- Associations
components:
schemas:
AssociationResponse:
type: object
properties:
resourceName:
type: string
resourceNamespace:
type: string
resourceId:
type: string
resourceType:
type: string
associations:
type: array
items:
$ref: '#/components/schemas/AssociationInfo'
SchemaEntity:
type: object
properties:
entityPath:
type: string
entityType:
type: string
enum:
- sr_record
- sr_field
Rule:
type: object
properties:
name:
type: string
description: Rule name
doc:
type: string
description: Rule doc
kind:
type: string
description: Rule kind
enum:
- TRANSFORM
- CONDITION
mode:
type: string
description: Rule mode
enum:
- UPGRADE
- DOWNGRADE
- UPDOWN
- WRITE
- READ
- WRITEREAD
type:
type: string
description: Rule type
tags:
uniqueItems: true
type: array
description: The tags to which this rule applies
items:
type: string
description: The tags to which this rule applies
params:
type: object
additionalProperties:
type: string
description: Optional params for the rule
description: Optional params for the rule
expr:
type: string
description: Rule expression
onSuccess:
type: string
description: Rule action on success
onFailure:
type: string
description: Rule action on failure
disabled:
type: boolean
description: Whether the rule is disabled
description: Rule
AssociationCreateOrUpdateRequest:
type: object
properties:
resourceName:
type: string
resourceNamespace:
type: string
resourceId:
type: string
resourceType:
type: string
associations:
type: array
items:
$ref: '#/components/schemas/AssociationCreateOrUpdateInfo'
Metadata:
type: object
properties:
tags:
type: object
additionalProperties:
uniqueItems: true
type: array
items:
type: string
properties:
type: object
additionalProperties:
type: string
sensitive:
uniqueItems: true
type: array
items:
type: string
description: User-defined metadata
Schema:
type: object
properties:
subject:
type: string
description: Name of the subject
example: User
version:
type: integer
description: Version number
format: int32
example: 1
id:
type: integer
description: Globally unique identifier of the schema
format: int32
example: 100001
guid:
type: string
description: Globally unique identifier of the schema. In Confluent Cloud, this field is returned only if Confluent-Accept-Unknown-Properties header is passed in
schemaType:
type: string
description: Schema type. In Confluent Cloud, this field is returned only if Confluent-Accept-Unknown-Properties header is passed in
example: AVRO
references:
type: array
description: References to other schemas
items:
$ref: '#/components/schemas/SchemaReference'
metadata:
$ref: '#/components/schemas/Metadata'
ruleset:
$ref: '#/components/schemas/RuleSet'
schema:
type: string
description: Schema definition string
example: '{"schema": "{"type": "string"}"}'
schemaTags:
type: array
description: Schema tags
items:
$ref: '#/components/schemas/SchemaTags'
ts:
type: integer
description: Timestamp when the schema version's record was last written; the version was registered then unless createTs is present. In Confluent Cloud, this field is returned only if Confluent-Accept-Unknown-Properties header is passed in
format: int64
createTs:
type: integer
description: Timestamp when the schema version was first registered. Present only when it differs from ts, i.e. the version's record was rewritten, as by a soft delete or an import; otherwise the version was registered at ts. In Confluent Cloud, this field is returned only if Confluent-Accept-Unknown-Properties header is passed in
format: int64
deleted:
type: boolean
description: Whether the schema has been deleted. In Confluent Cloud, this field is returned only if Confluent-Accept-Unknown-Properties header is passed in
ruleSet:
$ref: '#/components/schemas/RuleSet'
description: Schema
AssociationInfo:
type: object
properties:
subject:
type: string
associationType:
type: string
lifecycle:
type: string
enum:
- STRONG
- WEAK
frozen:
type: boolean
schema:
$ref: '#/components/schemas/Schema'
RegisterSchemaRequest:
type: object
properties:
version:
type: integer
description: Version number
format: int32
id:
type: integer
description: Globally unique identifier of the schema
format: int32
schemaType:
type: string
description: Schema type
references:
type: array
description: References to other schemas
items:
$ref: '#/components/schemas/SchemaReference'
metadata:
$ref: '#/components/schemas/Metadata'
ruleSet:
$ref: '#/components/schemas/RuleSet'
schema:
type: string
description: Schema definition string
schemaTagsToAdd:
type: array
items:
$ref: '#/components/schemas/SchemaTags'
schemaTagsToRemove:
type: array
items:
$ref: '#/components/schemas/SchemaTags'
propagateSchemaTags:
type: boolean
description: Schema register request
Association:
type: object
properties:
subject:
type: string
guid:
type: string
resourceName:
type: string
resourceNamespace:
type: string
resourceId:
type: string
resourceType:
type: string
associationType:
type: string
lifecycle:
type: string
enum:
- STRONG
- WEAK
frozen:
type: boolean
createTs:
type: integer
format: int64
updateTs:
type: integer
format: int64
description: Associations for the given subject
AssociationCreateOrUpdateInfo:
type: object
properties:
subject:
type: string
associationType:
type: string
lifecycle:
type: string
enum:
- STRONG
- WEAK
frozen:
type: boolean
schema:
$ref: '#/components/schemas/RegisterSchemaRequest'
normalize:
type: boolean
SchemaReference:
type: object
properties:
name:
type: string
description: Reference name
example: io.confluent.kafka.example.User
subject:
type: string
description: Name of the referenced subject
example: User
version:
type: integer
description: Version number of the referenced subject
format: int32
example: 1
description: Schema reference
SchemaTags:
type: object
properties:
schemaEntity:
$ref: '#/components/schemas/SchemaEntity'
tags:
type: array
items:
type: string
RuleSet:
type: object
properties:
migrationRules:
type: array
items:
$ref: '#/components/schemas/Rule'
domainRules:
type: array
items:
$ref: '#/components/schemas/Rule'
encodingRules:
type: array
items:
$ref: '#/components/schemas/Rule'
enableAt:
type: string
enum:
- ALL
- CLIENT
- GATEWAY
- SERVER
- NONE
description: Schema rule set
x-refined-from:
- schema-registry-api-spec.yaml
- schema-registry-openapi.yaml
x-tagGroups:
- name: Identity Access Management (v2)
tags:
- API Keys (iam/v2)
- Users (iam/v2)
- Service Accounts (iam/v2)
- Invitations (iam/v2)
- IP Groups (iam/v2)
- IP Filters (iam/v2)
- IP Filter Summaries (iam/v2)
- Role Bindings (iam/v2)
- Identity Providers (iam/v2)
- Jwks (iam/v2)
- Identity Pools (iam/v2)
- Group Mappings (iam/v2/sso)
- Certificate Authorities (iam/v2)
- Certificate Identity Pools (iam/v2)
- name: Org API (v2)
tags:
- Environments (org/v2)
- Organizations (org/v2)
- name: Notifications API (v1)
tags:
- Subscriptions (notifications/v1)
- Integrations (notifications/v1)
- Notification Types (notifications/v1)
- Resource Preferences (notifications/v1)
- Resource Subscriptions (notifications/v1)
- User Notifications (notifications/v1)
- name: Cluster Mgmt for Kafka (v2)
tags:
- Clusters (cmk/v2)
- name: Cluster Mgmt for ksqlDB (v2)
tags:
- Clusters (ksqldbcm/v2)
- name: Connect API (v1)
tags:
- Connectors (connect/v1)
- Lifecycle (connect/v1)
- Status (connect/v1)
- Managed Connector Plugins (connect/v1)
- Offsets (connect/v1)
- Custom Connector Plugins (connect/v1)
- Presigned Urls (connect/v1)
- Custom Connector Runtimes (connect/v1)
- name: Connect Artifact Management (v1)
tags:
- Connect Artifacts (cam/v1)
- Presigned Urls (cam/v1)
- name: Kafka API (v3)
tags:
- Cluster (v3)
- Configs (v3)
- ACL (v3)
- Consumer Group (v3)
- Partition (v3)
- Topic (v3)
- Records (v3)
- Cluster Linking (v3)
- Share Group (v3)
- Streams Group (v3)
- name: Service Quota API (v1)
tags:
- Applied Quotas (service-quota/v1)
- Scopes (service-quota/v1)
- name: Partner API (v2)
tags:
- Entitlements (partner/v2)
- Organizations (partner/v2)
- Signup (partner/v2)
- name: Cluster Mgmt for Schema Registry (v2)
tags:
- Regions (srcm/v2)
- Clusters (srcm/v2)
- name: Cluster Mgmt for Schema Registry (v3)
tags:
- Clusters (srcm/v3)
- name: Schema Registry API (v1)
tags:
- Compatibility (v1)
- Config (v1)
- Contexts (v1)
- Exporters (v1)
- Modes (v1)
- Schemas (v1)
- Subjects (v1)
- Key Encryption Keys (v1)
- Data Encryption Keys (v1)
- name: Catalog API (v1)
tags:
- Entity (v1)
- Search (v1)
- Types (v1)
- name: Stream Sharing API (v1)
tags:
- Provider Shared Resources (cdx/v1)
- Provider Shares (cdx/v1)
- Consumer Shared Resources (cdx/v1)
- Consumer Shares (cdx/v1)
- Shared Tokens (cdx/v1)
- Opt Ins (cdx/v1)
- name: Networking (v1)
tags:
- Networks (networking/v1)
- Peerings (networking/v1)
- Transit Gateway Attachments (networking/v1)
- Private Link Accesses (networking/v1)
- Network Link Services (networking/v1)
- Network Link Endpoints (networking/v1)
- Network Link Service Associations (networking/v1)
- IP Addresses (networking/v1)
- Private Link Attachments (networking/v1)
- Private Link Attachment Connections (networking/v1)
- DNS Forwarders (networking/v1)
- Access Points (networking/v1)
- DNS Records (networking/v1)
- Gateways (networking/v1)
- name: Security Token Service (v1)
tags:
- OAuth Tokens (sts/v1)
- name: Kafka Quota (v1)
tags:
- Client Quotas (kafka-quotas/v1)
- name: Bring Your Own Key (BYOK) Management (v1)
tags:
- Keys (byok/v1)
- name: Billing API (v1)
tags:
- Costs (billing/v1)
- name: Compute Pool Mgmt for Flink (v2)
tags:
- Compute Pools (fcpm/v2)
- Regions (fcpm/v2)
- Org Compute Pool Configs (fcpm/v2)
- name: SQL API (v1)
tags:
- Statements (sql/v1)
- Statement Results (sql/v1)
- Statement Exceptions (sql/v1)
- Connections (sql/v1)
- Agents (sql/v1)
- Tools (sql/v1)
- Materialized Tables (sql/v1)
- Materialized Table Versions (sql/v1)
- name: Provider Integration Management (v1)
tags:
- Integrations (pim/v1)
- name: Provider Integration Management (v2)
tags:
- Integrations (pim/v2)
- name: Artifact API (v1)
tags:
- Flink Artifacts (artifact/v1)
- Presigned Urls (artifact/v1)
- Flink Artifact Versions (artifact/v1)
- name: Custom Code Logging API (v1)
tags:
- Custom Code Loggings (ccl/v1)
- name: Tableflow (v1)
tags:
- Regions (tableflow/v1)
- Tableflow Topics (tableflow/v1)
- Catalog Integrations (tableflow/v1)
- name: Custom Connect Plugin Management (v1)
tags:
- Custom Connect Plugins (ccpm/v1)
- Presigned Urls (ccpm/v1)
- Custom Connect Plugin Versions (ccpm/v1)
- name: Unified Stream Manager (v1)
tags:
- Kafka Clusters (usm/v1)
- Connect Clusters (usm/v1)
- name: Endpoint (v1)
tags:
- Endpoints (endpoint/v1)
- name: Real Time Context Engine (v1)
tags:
- Rtce Topics (rtce/v1)
- Regions (rtce/v1)
- name: Analytics (v1alpha1)
tags:
- Statements (query/v1alpha1)