Aiven

Aiven Service:_Kafka API

The Service:_Kafka API from Aiven — 34 operation(s) for service:_kafka.

GitHub OpenAPI

Operations 49

POST /project/{project}/service/{service_name}/acl Add Aiven Kafka ACL entry #
GET /project/{project}/service/{service_name}/acl List Aiven ACL entries for Kafka service #
DELETE /project/{project}/service/{service_name}/acl/{kafka_acl_id} Delete a Kafka ACL entry #
POST /project/{project}/service/{service_name}/connectors Create a Kafka Connect connector #
GET /project/{project}/service/{service_name}/connectors Lists Kafka connectors #
DELETE /project/{project}/service/{service_name}/connectors/{connector_name} Delete Kafka Connect connector #
PUT /project/{project}/service/{service_name}/connectors/{connector_name} Edit 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}/kafka/acl Add a Kafka-native ACL entry #
GET /project/{project}/service/{service_name}/kafka/acl List Kafka-native ACL entries #
DELETE /project/{project}/service/{service_name}/kafka/acl/{kafka_acl_id} Delete a Kafka-native ACL entry #
GET /project/{project}/service/{service_name}/kafka/acl/{kafka_acl_id} Get single Kafka-native ACL entry #
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 List Kafka quotas #
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 #
POST /project/{project}/service/{service_name}/topic Create a Kafka topic #
GET /project/{project}/service/{service_name}/topic Get Kafka topic list #
DELETE /project/{project}/service/{service_name}/topic/{topic_name} Delete 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 #
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 #
POST /project/{project}/service/{service_name}/kafka/schema-registry/acl Add a Schema Registry ACL entry #
GET /project/{project}/service/{service_name}/kafka/schema-registry/acl List Schema Registry ACL entries #
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 #
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/{version_id} Get Schema Registry Subject version #
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 Get Schema Registry subject versions #
GET /project/{project}/service/{service_name}/kafka/schema/subjects/{subject_name}/versions/{version_id}/schema DEPRECATED: Get raw schema of a specific version in Schema Registry #
GET /project/{project}/service/{service_name}/kafka/schema/subjects Lists Schema Registry subjects #

Documentation

📖
Documentation
https://aiven.io/docs/tools/api
📖
Authentication
https://aiven.io/docs/platform/howto/create_authentication_token

Specifications

⚙
OpenAPI
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/openapi/aiven-service-kafka-api-openapi.yml

Schemas & Data

📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-service-create.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-service-list.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-project-create.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-account-auth.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-billing-group.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-organization-create.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-vpc-create.json
📊
JSONSchema
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/json-schema/aiven-user-info.json

Other Resources

🔗
Examples
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/examples/aiven-create-project.json
🔗
Examples
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/examples/aiven-create-kafka-service.json
🔗
Examples
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/examples/aiven-create-postgresql-service.json
🔗
Examples
https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/examples/aiven-list-services.json

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.
All 92 tools →

Call it yourself

curl for this page
This API 
curl "https://apis.io/api/v1/apis/aiven-service-kafka-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.

GitHub Google LinkedIn

A second provider on the same verified email joins the account you already have.

OpenAPI Specification

aiven-service-kafka-api-openapi.yml Raw ↑ 
openapi: 3.2.0
info:
  contact:
    email: support@aiven.io
    name: Aiven support team
    url: https://aiven.io/support-services
  title: 'Aiven API Documentation Service: Kafka API'
  version: v1
  x-logo:
    altText: Aiven logo
    backgroundColor: '#fafafa'
    href: https://api.aiven.io/doc
    url: https://aiven.io/assets/img/aiven-logo.png
  description: '# Introduction


    Direct link to openapi.json for use with external tools


    Aiven is a modern fully-managed open source data platform for streaming, storing, and analyzing data on any public cloud.'
servers:
- url: https://api.aiven.io/v1
tags:


# --- truncated at 32 KB (281 KB total) ---
# Full source: https://raw.githubusercontent.com/api-evangelist/aiven/refs/heads/main/openapi/aiven-service-kafka-api-openapi.yml