This version is still in development and is not considered stable yet. For the latest stable version, please use Korvet 0.19!

MCP Server

Korvet can expose a Model Context Protocol (MCP) server so AI agents such as Claude Code can inspect a running broker: list and describe topics, peek at messages, diagnose consumer-group lag, and check segment, offload and health state. All tools are read-only; nothing on this endpoint can create, alter or delete broker state.

Enabling

The MCP server is disabled by default. Enable it with:

korvet.mcp.enabled=true

This serves a streamable-HTTP MCP endpoint at /mcp on the Admin API port.

Authentication

When korvet.admin.security-enabled=true (the default), MCP clients must present a static bearer token:

korvet.mcp.token=<random-secret>

Clients send it as Authorization: Bearer <random-secret>. If no token is configured while admin security is enabled, every MCP request is rejected with 401. When admin security is disabled, the endpoint is open like the rest of the Admin API.

Connecting a client

With Claude Code:

claude mcp add --transport http korvet http://localhost:8080/mcp \
  --header "Authorization: Bearer <random-secret>"

Tools

Tool Description

Tool	Description
`korvet_list_topics`	List all topics with their configuration.
`korvet_describe_topic`	Partition count, retention, segment and storage configuration of one topic.
`korvet_topic_stats`	Produced messages/bytes, current message count, request counts.
`korvet_list_partitions`	Per-partition statistics for one topic or all topics.
`korvet_peek_messages`	Read messages without committing offsets; payloads base64-encoded unless `decode` is `utf8` or `json`.
`korvet_list_consumer_groups`	Active and durable consumer groups.
`korvet_describe_consumer_group`	Group state, members and assignments.
`korvet_consumer_group_offsets`	Committed offsets and lag per topic partition.
`korvet_segment_summaries`	Segment counts and sizes per tier across all topics.
`korvet_partition_segments`	Per-partition segment summaries of a topic.
`korvet_list_segments`	Full segment list of one topic partition.
`korvet_list_offload_jobs`	Remote-storage offload job status.
`korvet_health`	Overall health plus individual checks (Redis, remote storage).
`korvet_metrics`	Broker metrics summary.
`korvet_brokers`	Registered brokers, listeners and connections.
`korvet_storage_stats`	Remote (tiered) storage statistics.

korvet_list_topics

List all topics with their configuration.

korvet_describe_topic

Partition count, retention, segment and storage configuration of one topic.

korvet_topic_stats

Produced messages/bytes, current message count, request counts.

korvet_list_partitions

Per-partition statistics for one topic or all topics.

korvet_peek_messages

Read messages without committing offsets; payloads base64-encoded unless decode is utf8 or json.

korvet_list_consumer_groups

Active and durable consumer groups.

korvet_describe_consumer_group

Group state, members and assignments.

korvet_consumer_group_offsets

Committed offsets and lag per topic partition.

korvet_segment_summaries

Segment counts and sizes per tier across all topics.

korvet_partition_segments

Per-partition segment summaries of a topic.

korvet_list_segments

Full segment list of one topic partition.

korvet_list_offload_jobs

Remote-storage offload job status.

korvet_health

Overall health plus individual checks (Redis, remote storage).

korvet_metrics

Broker metrics summary.

korvet_brokers

Registered brokers, listeners and connections.

korvet_storage_stats

Remote (tiered) storage statistics.