Aiven MCP Server

Official MCP server for the Aiven cloud data platform. Manage PostgreSQL, Apache Kafka, and other Aiven services from AI assistants.

Developer Tools by Aiven OAuth2 active

Connect (Remote Server) GitHub Docs npm: mcp-aiven

Overview

The Aiven MCP server is the official Model Context Protocol integration from Aiven, the managed open source data platform. It lets AI assistants like Claude, Cursor, and VS Code Copilot inspect and operate Aiven projects, services, Kafka topics, PostgreSQL databases, and deployed applications using natural language. The server is available as a hosted endpoint at https://mcp.aiven.live/mcp or as a self-hostable Node.js package (mcp-aiven) on npm.

The server exposes roughly 40 tools grouped into core platform management (projects, VPCs, services, plans, pricing, metrics, logs), Kafka (topics, messages, Kafka Connect connectors, schema registry), PostgreSQL (extensions, query stats, PgBouncer pools, read/write SQL execution, AI query optimization), application deployment via VCS integrations, and natural language documentation search. Services like ClickHouse, Valkey, and OpenSearch are managed through the generic aiven_service_* tools rather than having dedicated tool families.

Notable features include a read-only mode (?read_only=true) and scoped tool exposure (?services_scope=kafka,pg) so you can restrict the agent surface area to specific service types. The repo carries a clear warning that destructive operations such as dropping databases or deleting services can be triggered by AI interpretation of prompts, so use read-only mode or scoped tokens when running in production contexts.

Tools

Tool	Description
`aiven_project_list`	List Aiven projects accessible to the authenticated user.
`aiven_project_get`	Get details of a specific Aiven project.
`aiven_list_project_clouds`	List available cloud regions for a project.
`aiven_project_vpc_list`	List VPCs configured for a project.
`aiven_service_list`	List services in a project (PostgreSQL, Kafka, ClickHouse, Valkey, OpenSearch, etc.).
`aiven_service_create`	Create a new managed service.
`aiven_service_get`	Get configuration and status of a service.
`aiven_service_update`	Update service configuration.
`aiven_service_type_plans`	List available plans for a given service type.
`aiven_service_plan_pricing`	Get pricing details for a service plan.
`aiven_service_metrics_fetch`	Fetch metrics for a service.
`aiven_service_application_metrics_get`	Fetch application-level metrics for a service.
`aiven_project_get_service_logs`	Retrieve service logs.
`aiven_service_query_activity`	Get recent query activity for a service.
`aiven_project_get_event_logs`	Get project audit/event logs.
`aiven_kafka_topic_list`	List Kafka topics in a service.
`aiven_kafka_topic_create`	Create a Kafka topic.
`aiven_kafka_topic_get`	Get details of a Kafka topic.
`aiven_kafka_topic_update`	Update a Kafka topic configuration.
`aiven_kafka_topic_delete`	Delete a Kafka topic.
`aiven_kafka_topic_message_list`	Read messages from a Kafka topic.
`aiven_kafka_topic_message_produce`	Produce a message to a Kafka topic.
`aiven_kafka_connect_available_connectors`	List Kafka Connect connector plugins available.
`aiven_kafka_connect_list`	List configured Kafka Connect connectors.
`aiven_kafka_connect_create_connector`	Create a Kafka Connect connector.
`aiven_kafka_connect_edit_connector`	Edit a Kafka Connect connector configuration.
`aiven_kafka_connect_get_connector_status`	Get status of a Kafka Connect connector.
`aiven_kafka_connect_pause_connector`	Pause a connector.
`aiven_kafka_connect_resume_connector`	Resume a connector.
`aiven_kafka_connect_restart_connector`	Restart a connector.
`aiven_kafka_connect_delete_connector`	Delete a connector.
`aiven_kafka_schema_registry_subjects`	List subjects in the Karapace schema registry.
`aiven_kafka_schema_registry_subject_version_get`	Get a specific subject version schema.
`aiven_pg_service_available_extensions`	List PostgreSQL extensions available on the service.
`aiven_pg_service_query_statistics`	Get PostgreSQL query statistics (pg_stat_statements).
`aiven_pg_bouncer_create`	Create a PgBouncer connection pool.
`aiven_pg_bouncer_update`	Update a PgBouncer pool.
`aiven_pg_bouncer_delete`	Delete a PgBouncer pool.
`aiven_pg_read`	Execute a read-only SQL query against a PostgreSQL service.
`aiven_pg_write`	Execute a write SQL statement against a PostgreSQL service.
`aiven_pg_optimize_query`	Use AI optimization to suggest query improvements.
`aiven_application_deploy`	Deploy an application from a connected VCS repository.
`aiven_application_redeploy`	Redeploy an existing application.
`aiven_vcs_integration_list`	List configured VCS integrations.
`aiven_vcs_integration_repository_list`	List repositories accessible via a VCS integration.
`aiven_docs_search`	Natural language search over Aiven documentation (hosted server only).

Setup Guide

Option 1: Remote hosted server (recommended)

The simplest path is to point your MCP client at Aiven's hosted endpoint. Authentication is handled via OAuth on the first connection.

Claude Code:

claude mcp add --scope user --transport http aiven-mcp "https://mcp.aiven.live/mcp"

Cursor:

{
  "mcpServers": {
    "aiven-mcp": {
      "url": "https://mcp.aiven.live/mcp"
    }
  }
}

VS Code (.vscode/mcp.json):

{
  "servers": {
    "aiven-mcp": {
      "type": "http",
      "url": "https://mcp.aiven.live/mcp"
    }
  }
}

Option 2: Local stdio via npx

Requires Node.js 18+ and an Aiven API token from https://console.aiven.io/profile/tokens.

{
  "mcpServers": {
    "aiven-mcp": {
      "command": "npx",
      "args": ["-y", "mcp-aiven"],
      "env": {
        "AIVEN_TOKEN": "your-token-here"
      }
    }
  }
}

Advanced configuration

Use query parameters or environment variables to restrict the agent's capabilities.

Read-only mode: https://mcp.aiven.live/mcp?read_only=true
Scope to specific services: https://mcp.aiven.live/mcp?services_scope=kafka,pg
Valid scopes: all, core, pg, kafka, application, integrations

Environment variables

AIVEN_TOKEN (stdio mode): Aiven API token
AIVEN_READ_ONLY (optional, default false): enable read-only mode
AIVEN_SERVICES_SCOPE (optional): comma-separated tool scopes
MCP_TRANSPORT (optional, default stdio): set to http for HTTP server mode
MCP_HOST (optional, default https://mcp.aiven.live): override OAuth resource host

Warning: The server can execute destructive operations such as dropping databases or deleting services based on AI interpretation of prompts. Use read-only mode or scoped tokens for production environments.

Use Cases

Provision a new PostgreSQL or Kafka service on the right cloud and plan after checking pricing options
Inspect Kafka topics, peek at messages, and manage Kafka Connect connectors (pause, restart, edit, delete) directly from an AI chat
Run ad hoc SQL against managed PostgreSQL with aiven_pg_read and get AI-suggested rewrites via aiven_pg_optimize_query
Pull service metrics, query activity, and event logs to triage incidents without leaving the editor
Search Aiven documentation in natural language and deploy applications from connected VCS repositories

Example Prompts

"List all PostgreSQL services in my production project and show their current plan and CPU usage."
"Create a new Kafka topic called orders.v2 with 12 partitions and replication factor 3 on the analytics-kafka service."
"Read the last 100 rows from the events table in the prod-pg service and suggest an index that would speed up the slowest query."
"Pause the s3-sink Kafka Connect connector on analytics-kafka and tell me its last error."
"Search Aiven docs for how to enable PITR on PostgreSQL and summarize the steps."

Pros

Officially maintained by Aiven in the Aiven-Open GitHub org, Apache 2.0 licensed
Offers both a zero-install hosted endpoint with OAuth and a self-hostable npm package
Broad coverage: ~40 tools spanning project admin, Kafka, PostgreSQL, Kafka Connect, schema registry, and applications
Supports read-only mode and per-service scoping to limit blast radius for agents

Limitations

No dedicated tools for ClickHouse, Valkey, OpenSearch, or M3; these are managed only through the generic aiven_service_* tools
Powerful write tools (aiven_pg_write, aiven_service_update, topic and connector deletes) can be destructive if invoked by a misinterpreting agent
Requires an Aiven account and API token; metrics and some features depend on paid service tiers

Alternatives

Neon MCP server for managed Postgres branching workflows
Supabase MCP server for Postgres plus auth, storage, and edge functions
Confluent MCP server for managed Apache Kafka and Flink on Confluent Cloud