# Confluent MCP for AI Agents AI Agent Connect > Confluent MCP lets your AI agent manage Kafka clusters, topics, and connectors directly in Confluent Cloud. It turns natural language into infrastructure actions, so you can check cluster health, list active topics, or audit your streaming environment without jumping between tabs. ## Overview - **Category:** industry-titans - **Price:** Free - **Endpoint:** https://edge.vinkius.com/vk_preview_0XFjfUiQ7l74QzUowmTvlFqNPqR8GzPSJEppI50O/ai-agent-connect - **Tags:** apache-kafka, data-streaming, event-processing, cluster-monitoring, topic-management ## Description Connect your AI to Confluent Cloud, the managed data streaming platform built on Apache Kafka. This Connector lets you handle the heavy lifting of infrastructure management through a simple chat interface. Instead of hunting through dashboards to find a specific metric or manually verifying topic configurations, you can just ask your agent to do it. You can check if a cluster is healthy, see what topics are running in a specific environment, or audit your service accounts in seconds. It turns your streaming infrastructure into a responsive system where you get answers instantly rather than spending time digging for them. By bringing these capabilities into your workflow via the Vinkius catalog, you can stay in your flow state while keeping your data pipelines running smoothly. It handles the API calls so you can focus on the logic of your data. ## Tools ### get_cluster_details Pulls configuration, endpoint URLs, and provisioning status for a specific Kafka cluster. ### list_cloud_api_keys Shows all API keys currently active in your Confluent Cloud account. ### list_connectors Shows all source and sink connectors with their current status in a specific cluster. ### list_environments Identifies the environment IDs you need to perform cluster or connector operations. ### list_service_accounts Lists all service accounts in your organization to help audit programmatic access. ### list_topics Shows all topics in a cluster including partition counts and replication settings. ### list_clusters Lists all Kafka clusters along with their cloud provider, region, and status. ## Prompt Examples **Prompt:** ``` Check the health of the 'main-eu' Kafka cluster. ``` **Response:** ``` Cluster 'main-eu' is healthy. All nodes are available, CPU utilization averages 42%, and no alerts have been logged in the past 24 hours. ``` **Prompt:** ``` List all active topics in the 'default_env' environment. ``` **Response:** ``` 8 topics found in 'default_env': - 'user-actions': 12 partitions, 2.3K msgs/sec - 'payment-events': 6 partitions, 850 msgs/sec - 'analytics-pipeline': 8 partitions, 1.1K msgs/sec Would you like partition details for any of these? ``` **Prompt:** ``` Check the status of the 'mysql-source' connector. ``` **Response:** ``` The 'mysql-source' connector is actively running. There are 0 failed tasks, and it has successfully processed 45,000 records in the last hour. ``` ## Capabilities ### Check cluster health metrics Get instant updates on node availability and CPU usage for your Kafka clusters. ### List and create Kafka topics View all active topics or spin up new ones with specific partition counts. ### Audit environment connectors See which source and sink connectors are active and check their current status. ### Manage service accounts Retrieve a list of service accounts to audit programmatic access across your organization. ### View cloud API keys Quickly see all active API keys in your Confluent Cloud account for security reviews. ### Inspect cluster endpoints Pull configuration details and endpoint URLs for specific Kafka environments. ## Use Cases ### Checking cluster health during an outage A data engineer asks the agent to check the 'main-eu' cluster health, and it immediately reports node availability and CPU usage. ### Auditing production connectors A DevOps lead asks the agent to list all connectors in production to ensure every source and sink is running correctly. ### Planning new stream integrations An architect asks the agent to list all topics to see current partition patterns and replication settings before designing a new flow. ### Security access audits A security admin asks the agent to list all cloud API keys and service accounts to ensure only authorized keys remain active. ## Benefits - Stop manual dashboard hopping by using `list_clusters` to get a high-level view of your entire infrastructure in one go. - Speed up your development cycle by using `list_topics` to quickly check partition counts and replication settings without manual queries. - Keep your security tight by using `list_service_accounts` to audit programmatic access across your Confluent Cloud organization. - Reduce deployment friction by using `list_connectors` to verify that your source and sink connectors are actually active. - Get instant infrastructure clarity by using `get_cluster_details` to pull endpoints and provisioning status for specific environments. ## How It Works The bottom line is you get a conversational interface for your entire Confluent Cloud infrastructure. 1. Connect your Confluent Cloud API Key and Secret to the Connector. 2. Tell your AI client what you need to see or change in your Kafka environment. 3. Get real-time status updates or configuration changes instantly. ## Frequently Asked Questions **Can the Confluent MCP actually create new topics?** Yes, it can create topics and let you check their configurations instantly. This lets you manage your Kafka infrastructure without leaving your chat interface. **Will the Confluent MCP show me my cluster's CPU usage?** Yes, it retrieves health metrics including node availability and CPU metrics. You can get a real-time look at your cluster's performance. **Does the Confluent MCP work for monitoring connectors?** It lists all source and sink connectors and shows their current running status. This is great for verifying that your data pipelines are actually active. **Can I use the Confluent MCP to audit my security keys?** You can list all cloud API keys and service accounts to keep your organization's access secure. It makes auditing programmatic access much faster. **Is the Confluent MCP good for checking Kafka partition counts?** It provides the partition count and replication configuration for all topics in a cluster. This helps you verify your data distribution at a glance. **How do I get a Confluent Cloud API Key?** Log in to your Confluent Cloud dashboard. Go to **Cloud API Keys** under the administration menu. Click **Add key**, select the scope, and copy both the API Key and Secret. **What is an Environment in Confluent?** An Environment is a logical boundary containing clusters, schema registries, and connectors. You often need the Environment ID when querying specific resources. **Can the agent consume messages directly?** This integration focuses on control-plane tasks: managing topics, monitoring cluster status, and listing connectors. Direct message consumption from streams is not supported.