Confluent Cloud
Manage Confluent Cloud environments, Kafka clusters, topics, connectors, service accounts, API keys, and metrics.
Tools
| Name | Description |
|---|---|
list_environmentsList Confluent Cloud environments. | List Confluent Cloud environments. |
get_environmentGet a Confluent Cloud environment. | Get a Confluent Cloud environment. |
list_kafka_clustersList Kafka clusters in a Confluent Cloud environment. | List Kafka clusters in a Confluent Cloud environment. |
get_kafka_clusterGet a Kafka cluster by ID and environment. | Get a Kafka cluster by ID and environment. |
list_topicsList Kafka topics for a Confluent Cloud cluster through its Kafka REST endpoint. | List Kafka topics for a Confluent Cloud cluster through its Kafka REST endpoint. |
get_topicGet Kafka topic metadata from a Confluent Cloud cluster. | Get Kafka topic metadata from a Confluent Cloud cluster. |
create_topicCreate a Kafka topic in a Confluent Cloud cluster. Requires explicit confirmation because it provisions a new cluster resource. | Create a Kafka topic in a Confluent Cloud cluster. Requires explicit confirmation because it provisions a new cluster resource. |
delete_topicDelete a Kafka topic from a Confluent Cloud cluster. Requires exact topic-name confirmation. | Delete a Kafka topic from a Confluent Cloud cluster. Requires exact topic-name confirmation. |
list_service_accountsList Confluent Cloud service accounts. | List Confluent Cloud service accounts. |
get_service_accountGet a Confluent Cloud service account. | Get a Confluent Cloud service account. |
list_api_keysList Confluent Cloud API keys, optionally filtered by owner or resource. | List Confluent Cloud API keys, optionally filtered by owner or resource. |
get_api_keyGet Confluent Cloud API key metadata. | Get Confluent Cloud API key metadata. |
list_metric_descriptorsList metric descriptors from the Confluent Metrics API. | List metric descriptors from the Confluent Metrics API. |
query_metricsRun a bounded Confluent Metrics API query JSON body. | Run a bounded Confluent Metrics API query JSON body. |
list_connectorsList managed Kafka Connect connectors in a Confluent Cloud environment and connect cluster. | List managed Kafka Connect connectors in a Confluent Cloud environment and connect cluster. |
get_connectorGet managed Kafka Connect connector configuration. | Get managed Kafka Connect connector configuration. |
get_connector_statusGet managed Kafka Connect connector and task status. | Get managed Kafka Connect connector and task status. |
create_connectorCreate a managed Kafka Connect connector. Requires explicit confirmation because it provisions a connector. | Create a managed Kafka Connect connector. Requires explicit confirmation because it provisions a connector. |
delete_connectorDelete a managed Kafka Connect connector. Requires exact connector-name confirmation. | Delete a managed Kafka Connect connector. Requires exact connector-name confirmation. |
custom_api_callMake a guarded custom call to the Confluent Cloud management, metrics, or Kafka REST API. | Make a guarded custom call to the Confluent Cloud management, metrics, or Kafka REST API. |
Triggers
| Name | Description |
|---|---|
kafka_cluster_status_changedPolls Kafka clusters in an environment and triggers when status changes. | Polls Kafka clusters in an environment and triggers when status changes. |
connector_status_changedPolls a Confluent Cloud managed connector and triggers when connector or task status changes. | Polls a Confluent Cloud managed connector and triggers when connector or task status changes. |
Quick Start
import { WeavzClient } from '@weavz-io/sdk'
const weavz = new WeavzClient({ apiKey: 'wvz_...' })
const result = await weavz.actions.execute('confluent-cloud', 'list_environments', {
workspaceId: '550e8400-e29b-41d4-a716-446655440000',
integrationAlias: 'confluent-cloud',
input: { /* ... */ },
})Related Integrations
Works well with
Frequently Asked Questions
How do I connect Confluent Cloud to my app?
Use Weavz Hosted Connect for Custom authentication. Install the SDK, create a connection through the connect portal or API, then execute tools programmatically.
What tools does Confluent Cloud support?
Confluent Cloud supports 20 tools including List Environments, Get Environment, List Kafka Clusters, Get Kafka Cluster, List Topics, and more.
Can I use Confluent Cloud with AI agents?
Yes. Add Confluent Cloud to an MCP server in Tool Mode or Code Mode. Code Mode provides 3 meta-tools with on-demand API discovery so agents can compose stateful workflows without loading every action schema up front.
Can Confluent Cloud be used in stateful agent workflows?
Yes. Agents can combine Confluent Cloud tools with Filesystem, State KV, Human Gates, input partials, and other workspace integrations while keeping execution scoped to the selected workspace or end user.
What authentication does Confluent Cloud use?
Confluent Cloud uses Custom. Weavz stores credentials securely and uses them for authorized action execution.
How much does the Confluent Cloud integration cost?
The Confluent Cloud integration is included on all Weavz plans including the free tier with 20,000 actions per month. No credit card required.
What triggers does Confluent Cloud support?
Confluent Cloud supports 2 triggers including Kafka Cluster Status Changed, Connector Status Changed.
Connect Confluent Cloud in minutes
Get 20,000 free action executions every month. No credit card required.