Loading...
npx @confluentinc/mcp-confluent --generate-key{
"mcpServers": {
"confluent": {
"command": "node",
"args": [
"/path/to/confluent-mcp-server/dist/index.js",
"--env-file",
"/path/to/confluent-mcp-server/.env",
]
}
}
}Create Kafka TopicCreates a new Kafka topic with specified configurations.
Creates new resources, impacting cluster capacity and potentially data governance.
Delete Kafka TopicDeletes an existing Kafka topic, including its data.
Destructive operation that permanently removes data.
List Kafka TopicsLists all Kafka topics in the cluster.
Read-only operation with no side effects.
Create Flink SQL StatementCreates a new Flink SQL statement for data processing.
Creates a new data processing job that could consume resources.
Delete Flink SQL StatementDeletes an existing Flink SQL statement.
Removes a data processing job, potentially disrupting data pipelines.
List ConnectorsLists all Kafka Connect connectors.
Read-only operation.
Create ConnectorCreates a new Kafka Connect connector.
Creates a new connector, impacting data flow and resource utilization.
Delete ConnectorDeletes a Kafka Connect connector.
Removes a connector, potentially disrupting data ingestion or egress.
This server provides some security measures like API key authentication and host validation. However, the ability to perform write and delete operations on critical infrastructure components means that compromised credentials could lead to significant damage. Use with caution and restrict API key access.