Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| KAFKA_CLIENT_ID | No | Client ID for connection | kafka-mcp |
| KAFKA_BOOTSTRAP_SERVERS | Yes | Comma-separated list of broker urls (e.g., localhost:9092). |
Capabilities
Features and capabilities supported by this server
| Capability | Details |
|---|---|
| tools | {
"listChanged": true
} |
| prompts | {
"listChanged": false
} |
| resources | {
"subscribe": false,
"listChanged": false
} |
| experimental | {} |
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| describe_cluster | Returns information about the Kafka cluster (brokers, controller). |
| describe_brokers | Returns a list of brokers with their details. |
| list_topics | Returns a list of all topic names in the cluster. |
| describe_topic | Returns detailed information about a specific topic. |
| create_topic | Creates a new topic. |
| delete_topic | Deletes a topic. |
| create_partitions | Increases the number of partitions for a topic. Note: Partition count can only be increased, not decreased. |
| describe_configs | Get dynamic configs for a resource. resource_type: "topic", "broker", or "group" (case insensitive) |
| alter_configs | Update dynamic configs for a resource. resource_type: "topic", "broker", or "group" configs: Dictionary of config key-value pairs |
| consume_messages | Consumes messages from a topic. offset_spec: 'earliest', 'latest', or specific integer offset. timeout: seconds to wait for messages. |
| list_consumer_groups | Lists all consumer groups. |
| describe_consumer_group | Describes a specific consumer group. |
| get_consumer_group_offsets | Get the committed offsets and lag for a specific consumer group and topic. Returns the committed offset, high/low watermarks, and calculated lag for each partition. |
| reset_consumer_group_offset | Resets the offset of a consumer group using AdminClient. offset_spec: 'earliest', 'latest', or a specific integer offset string. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if the group is active or STABLE. |
| rewind_consumer_group_offset_by_timestamp | Rewinds consumer group offsets manually based on a specific timestamp. Finds offsets matching the timestamp using Consumer, then sets using AdminClient. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if the group is active or STABLE. |
| produce_message | Produces a message to a topic. |
Prompts
Interactive templates invoked by user choice
| Name | Description |
|---|---|
No prompts | |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |