/
AI
aiven
Search skmtc
⌘K
Docs
Sign in
Docs
History
Schema
Generate
Filter operations
Account
36
AIGateway
7
Application_Users
8
Authentication_Methods
3
Billing
6
BillingGroup
18
Cloud_platforms
4
Custom_Cloud
7
Domains
5
Groups
7
Kafka_Connect_Custom_Plugins
18
OAuth2
1
Organization_Vpc
12
OrganizationBillingGroup
10
OrganizationEmissions
1
OrganizationPaymentMethod
9
Organizations
36
Payment
4
Permissions
3
Project
35
Project_Billing
4
Project_Key_Management
1
Secrets
8
Service
56
Service_Integrations
12
Service:_Application
1
Service:_ClickHouse
13
Service:_Flink
32
Service:_Kafka
50
get
/project/{project}/service/{service_name}/acl
List Aiven ACL entries for Kafka service
post
/project/{project}/service/{service_name}/acl
Add Aiven Kafka ACL entry
delete
/project/{project}/service/{service_name}/acl/{kafka_acl_id}
Delete a Kafka ACL entry
get
/project/{project}/service/{service_name}/connectors
Lists Kafka connectors
post
/project/{project}/service/{service_name}/connectors
Create a Kafka Connect connector
put
/project/{project}/service/{service_name}/connectors/{connector_name}
Edit Kafka Connect connector
delete
/project/{project}/service/{service_name}/connectors/{connector_name}
Delete Kafka Connect connector
get
/project/{project}/service/{service_name}/available-connectors
Get available Kafka Connect connectors
get
/project/{project}/service/{service_name}/connector-plugins/{connector_name}/configuration
Get Kafka Connect connector configuration schema
get
/project/{project}/service/{service_name}/connectors/{connector_name}/status
Get a Kafka Connect Connector status
post
/project/{project}/service/{service_name}/connectors/{connector_name}/pause
Pause a Kafka Connect Connector
post
/project/{project}/service/{service_name}/connectors/{connector_name}/restart
Restart a Kafka Connect Connector
post
/project/{project}/service/{service_name}/connectors/{connector_name}/tasks/{task_id}/restart
Restart a Kafka Connect Connector task
post
/project/{project}/service/{service_name}/connectors/{connector_name}/resume
Resume a Kafka Connect Connector
post
/project/{project}/service/{service_name}/connectors/{connector_name}/stop
Stop a Kafka Connect Connector
post
/project/{project}/service/{service_name}/validate-custom-plugin-classes
Check that a custom plugin file can be installed on a service without connector class conflicts
get
/project/{project}/service/{service_name}/kafka/acl
List Kafka-native ACL entries
post
/project/{project}/service/{service_name}/kafka/acl
Add a Kafka-native ACL entry
get
/project/{project}/service/{service_name}/kafka/acl/{kafka_acl_id}
Get single Kafka-native ACL entry
delete
/project/{project}/service/{service_name}/kafka/acl/{kafka_acl_id}
Delete a Kafka-native ACL entry
get
/project/{project}/service/{service_name}/quota
List Kafka quotas
post
/project/{project}/service/{service_name}/quota
Create Kafka quota
delete
/project/{project}/service/{service_name}/quota
Delete Kafka quota
get
/project/{project}/service/{service_name}/quota/describe
Describe Specific Kafka quotas
get
/project/{project}/service/{service_name}/kafka/tiered-storage/storage-usage/by-topic
Get the Kafka tiered storage object storage usage by topic
get
/project/{project}/service/{service_name}/kafka/tiered-storage/storage-usage/total
Get the Kafka tiered storage total object storage usage
get
/project/{project}/service/{service_name}/kafka/tiered-storage/summary
Get the Kafka tiered storage summary
get
/project/{project}/service/{service_name}/topic
Get Kafka topic list
post
/project/{project}/service/{service_name}/topic
Create a Kafka topic
get
/project/{project}/service/{service_name}/topic/{topic_name}
Get Kafka topic info
put
/project/{project}/service/{service_name}/topic/{topic_name}
Update a Kafka topic
delete
/project/{project}/service/{service_name}/topic/{topic_name}
Delete a Kafka topic
post
/project/{project}/service/{service_name}/kafka/rest/topics/{topic_name}/messages
List kafka topic messages
post
/project/{project}/service/{service_name}/kafka/rest/topics/{topic_name}/produce
Produce message into a kafka topic
get
/project/{project}/service/{service_name}/kafka/schema-registry/acl
List Schema Registry ACL entries
post
/project/{project}/service/{service_name}/kafka/schema-registry/acl
Add a Schema Registry ACL entry
delete
/project/{project}/service/{service_name}/kafka/schema-registry/acl/{schema_registry_acl_id}
Delete a Schema Registry ACL entry
post
/project/{project}/service/{service_name}/kafka/schema/compatibility/subjects/{subject_name}/versions/{version_id}
Check compatibility of schema in Schema Registry
get
/project/{project}/service/{service_name}/kafka/schema/config
Get global configuration for Schema Registry
put
/project/{project}/service/{service_name}/kafka/schema/config
Edit global configuration for Schema Registry
get
/project/{project}/service/{service_name}/kafka/schema/schemas/ids/{schema_id}
Get schema in Schema Registry
get
/project/{project}/service/{service_name}/kafka/schema/config/{subject_name}
Get configuration for Schema Registry subject
put
/project/{project}/service/{service_name}/kafka/schema/config/{subject_name}
Edit configuration for Schema Registry subject
delete
/project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}
Delete Schema Registry subject
get
/project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}/versions/{version_id}
Get Schema Registry Subject version
delete
/project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}/versions/{version_id}
Delete Schema Registry subject version
get
/project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}/versions
Get Schema Registry subject versions
post
/project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}/versions
Register a new Schema in Schema Registry
get
/project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}/versions/{version_id}/schema
Get raw schema of a specific version in Schema Registry
get
/project/{project}/service/{service_name}/kafka/schema/subjects
Lists Schema Registry subjects
Service:_Kafka_MirrorMaker
5
Service:_Managed_Agents
11
Service:_MySQL
5
Service:_OpenSearch
24
Service:_PostgreSQL
10
Service:_Thanos
1
StaticIP
7
Upgrade_pipeline
6
Users
36
Service:_Kafka
Copy
Copy Markdown
Copy Markdown
Copying…
Copied
Copy failed
Changes to Add a Schema Registry ACL entry
post
/project/{project}/service/{service_name}/kafka/schema-registry/acl
Mar 16, 2026
402066a999a1
Revision changes
info
added the non-success response with the status
400