Which integrations are available for this server?

Allows AI assistants to interact with Apache Kafka clusters via AKHQ's REST API, providing tools for managing topics, consumer groups, schema registry, nodes/brokers, Kafka Connect, ksqlDB, and ACLs.

How do I use AKHQ MCP Server?

1. Click on "Install Server". 2. Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state. 3. In the chat, type @ followed by the MCP server name and your instructions, e.g., "@AKHQ MCP Server list all topics in the dev environment" That's it! The server will respond to your query, and you can continue using it as needed. Here is a step-by-step guide with screenshots.

AKHQ MCP Server

by seb-noirot

Overview Schema Related Servers Score Discussions

JavaScript

Remote

AKHQ MCP Server

An MCP (Model Context Protocol) server for AKHQ — the GUI for Apache Kafka.

Enables AI assistants (Claude, Cursor, etc.) to interact with Kafka clusters through AKHQ's REST API.

Features

Multi-environment support — configure multiple AKHQ instances (dev, staging, prod) and switch between them at runtime
Flexible authentication — supports no auth, HTTP Basic auth, and Bearer auth
Comprehensive AKHQ API coverage — topics, consumer groups, schema registry, nodes/brokers, Kafka Connect, ksqlDB, ACLs

Related MCP server: KafkaIQ

Installation

npm install
npm run build

Or run directly via npx:

{
  "mcpServers": {
    "akhq": {
      "command": "npx",
      "args": ["akhq-mcp-server"]
    }
  }
}

Configuration

Option 1: Config file (recommended for multiple environments)

Set the AKHQ_CONFIG_FILE environment variable to point to a JSON config file:

AKHQ_CONFIG_FILE=/path/to/akhq-config.json npx akhq-mcp-server

Example config file (akhq-config.json):

{
  "environments": [
    {
      "name": "local",
      "baseUrl": "http://localhost:8080",
      "auth": { "type": "none" }
    },
    {
      "name": "dev",
      "baseUrl": "https://akhq-dev.example.com",
      "auth": {
        "type": "basic",
        "username": "admin",
        "password": "secret"
      }
    },
    {
      "name": "prod",
      "baseUrl": "https://akhq-prod.example.com",
      "auth": {
        "type": "bearer",
        "token": "eyJhbGci..."
      }
    }
  ],
  "defaultEnvironment": "local"
}

Auth types:

"none" — no authentication
"basic" — HTTP Basic authentication (username + password)
"bearer" — Bearer authentication

Option 2: Environment variables (single environment)

Variable	Description	Default
`AKHQ_BASE_URL`	Base URL of your AKHQ instance	`http://localhost:8080`
`AKHQ_ENV_NAME`	Name for this environment	`default`
`AKHQ_AUTH_TYPE`	Auth type: `none`, `basic`, or `bearer`	`none`
`AKHQ_AUTH_USERNAME`	Username (for `basic` auth)
`AKHQ_AUTH_PASSWORD`	Password (for `basic` auth)
`AKHQ_AUTH_TOKEN`	Bearer token (for `bearer` auth)

Example with basic auth:

AKHQ_BASE_URL=https://akhq.example.com \
AKHQ_AUTH_TYPE=basic \
AKHQ_AUTH_USERNAME=admin \
AKHQ_AUTH_PASSWORD=secret \
node dist/main.js

MCP Client Setup

Claude Desktop

Add to ~/Library/Application Support/Claude/claude_desktop_config.json:

{
  "mcpServers": {
    "akhq": {
      "command": "node",
      "args": ["/path/to/akhq-mcp-server/dist/main.js"],
      "env": {
        "AKHQ_CONFIG_FILE": "/path/to/akhq-config.json"
      }
    }
  }
}

Cursor

Add to .cursor/mcp.json in your project or globally:

{
  "mcpServers": {
    "akhq": {
      "command": "node",
      "args": ["/path/to/akhq-mcp-server/dist/main.js"],
      "env": {
        "AKHQ_BASE_URL": "http://localhost:8080"
      }
    }
  }
}

Available Tools

Environment Management

Tool	Description
`list_environments`	List all configured AKHQ environments
`set_environment`	Switch the active AKHQ environment
`get_current_environment`	Get the currently active environment

General

Tool	Description
`get_auths`	Get all auth details for current instance
`get_cluster`	Get all cluster info
`get_me`	Get current user info
`get_topic_defaults_configs`	Get default topic configuration

Topics

Tool	Description
`get_topics`	List all topics
`post_topic`	Create a new topic
`get_topic`	Get topic details
`delete_topic`	Delete a topic
`get_topic_configs`	Get topic configuration
`post_topic_configs`	Update topic configuration
`get_topic_logs`	Get topic messages
`post_topic_produce`	Produce a message to a topic
`delete_topic_records`	Delete records from a topic
`get_topic_acls`	Get ACLs for a topic

Consumer Groups

Tool	Description
`get_groups`	List all consumer groups
`get_group_by_name`	Get consumer group details
`delete_group`	Delete a consumer group
`get_group_offsets`	Get consumer group offsets
`post_group_offsets`	Update consumer group offsets
`get_group_acls`	Get ACLs for a consumer group
`get_group_members`	Get consumer group members
`get_group_topics`	Get topics for a consumer group

Schema Registry

Tool	Description
`get_schemas`	List all schemas
`post_schema`	Create a new schema
`get_schema_by_subject`	Get schema by subject
`delete_schema`	Delete a schema
`get_schema_versions`	Get all versions of a schema
`get_schema_version`	Get a specific schema version

Nodes / Brokers

Tool	Description
`get_nodes`	List all nodes
`get_node`	Get node details
`get_node_configs`	Get node configuration
`post_node_configs`	Update node configuration
`get_node_logs`	Get node log configuration

Kafka Connect

Tool	Description
`get_connects`	List all connectors
`post_connect`	Create a connector
`get_connect_by_name`	Get connector details
`delete_connect`	Delete a connector
`get_connect_configs`	Get connector configuration
`post_connect_configs`	Update connector configuration
`get_connect_pause`	Pause a connector
`get_connect_resume`	Resume a connector
`get_connect_restart`	Restart a connector
`get_connect_tasks`	Get connector tasks
`get_connect_task_restart`	Restart a connector task
`get_connect_plugins`	List connect plugins

ksqlDB

Tool	Description
`get_ksqldb_info`	Get ksqlDB server info
`get_ksqldb_queries`	List ksqlDB queries
`get_ksqldb_streams`	List ksqlDB streams
`get_ksqldb_tables`	List ksqlDB tables
`put_ksqldb_execute`	Execute a ksqlDB statement
`put_ksqldb_query`	Execute a ksqlDB pull query

ACLs

Tool	Description
`get_acls`	List all ACLs for a cluster
`get_acls_by_principal`	Get ACLs for a specific principal

Development

npm run build    # Compile TypeScript
npm run dev      # Watch mode

License

MIT

This server cannot be installed

license - permissive license

quality - not tested

maintenance

How are these scores calculated?

Maintenance

–Maintainers

–Response time

–Release cycle

–Releases (12mo)

Commit activity

Resources

Need Help?

Related Servers

Unclaimed servers have limited discoverability.

Looking for Admin?

If you are the server author, to access and configure the admin panel.

Related MCP Servers

Kafka MCP Server
Databases App Automation Developer Tools
DevarshKumbhare
A
license
-
quality
D
maintenance
Enables interaction with Apache Kafka topics, allowing users to publish messages to and read messages from Kafka instances through natural language.
Updated a year ago (2025-06-22 11:45 UTC)
Apache 2.0
KafkaIQ
Monitoring Observability
ojhaayush03
F
license
-
quality
D
maintenance
Enables AI assistants to manage and monitor Apache Kafka clusters through natural language, providing real-time operations, health monitoring, consumer lag analysis, and temporal trend detection for intelligent cluster management.
Updated 8 months ago (2025-12-29 03:27 UTC)
Kafka MCP Server
Databases App Automation Data Platforms
shivamxtech
A
license
-
quality
C
maintenance
Enables AI agents to interact with Apache Kafka through natural language, supporting operations like producing/consuming messages, managing topics, and querying brokers, partitions, and consumer group offsets.
Updated a year ago (2025-06-19 12:45 UTC)
1
MIT
Kafka MCP Server
Data Platforms Developer Tools
Joel-hanson
A
license
-
quality
D
maintenance
Enables interaction with Kafka clusters via MCP, supporting topic management (list, create, delete, inspect), connection initialization, and more through natural language.
Updated a year ago (2025-06-07 06:01 UTC)
1
Apache 2.0

View all related MCP servers

Related MCP Connectors

GitHub
Connect AI assistants to GitHub - manage repos, issues, PRs, and workflows through natural language.
mcp
Connect your AI assistants to Keboola and expose your data, transformations, SQL queries, ...
hithereiamaliff-mcp-nextcloud
A comprehensive Model Context Protocol (MCP) server that enables AI assistants to interact with yo…

View all MCP Connectors

Latest Blog Posts

Who's Calling? MCP Hosts Are an Identity Blind Spot (And the Spec Knows It)
By Om-Shree-0709 on July 25, 2026.
mcp
Agent Identity
OAuth 2.1
Your AI Chatbot Just Exposed Your CEO's Salary to an Intern
By Om-Shree-0709 on July 2, 2026.
Agent Identity
MCP Security
OAuth Delegation
Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)
By Om-Shree-0709 on June 30, 2026.
Agentic Ai
Prompt Injection
WebAssembly

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/seb-noirot/akhq-mcp-server'

If you have feedback or need assistance with the MCP directory API, please join our Discord server

AKHQ MCP Server

Features

Installation

Configuration

Option 1: Config file (recommended for multiple environments)

Option 2: Environment variables (single environment)

MCP Client Setup

Claude Desktop

Cursor

Available Tools

Environment Management

General

Topics

Consumer Groups

Schema Registry

Nodes / Brokers

Kafka Connect

ksqlDB

ACLs

Development

License

Maintenance

Resources

Looking for Admin?

Related MCP Servers

Kafka MCP Server

KafkaIQ

Kafka MCP Server

Kafka MCP Server

Related MCP Connectors

Latest Blog Posts

MCP directory API