LogoSTMCP
Download
mcp-confluent

mcp-confluent

An MCP server implementation that enables AI assistants to interact with Confluent Cloud REST APIs for managing Kafka topics, connectors, and Flink SQL statements through natural language interactions.

Tools

1. list-topics

List all topics in the Kafka cluster.

2. create-topics

Create one or more Kafka topics.

3. delete-topics

Delete the topic with the given names.

4. produce-message

Produce records to a Kafka topic with support for Confluent Schema Registry serialization.

5. consume-messages

Consumes messages from one or more Kafka topics with automatic deserialization of Schema Registry encoded messages.

Retrieve a sorted, filtered, paginated list of all statements.

Make a request to create a statement.

Make a request to read a statement and its results.

Make a request to delete a statement.

10. list-connectors

Retrieve a list of names of the active connectors.

11. read-connector

Get information about the connector.

12. create-connector

Create a new connector and return the new connector information.

13. delete-connector

Delete an existing connector and return a success message.

14. search-topics-by-tag

List all topics in the Kafka cluster with the specified tag.

15. search-topics-by-name

List all topics in the Kafka cluster matching the specified name.

16. create-topic-tags

Create new tag definitions in Confluent Cloud.

17. delete-tag

Delete a tag definition from Confluent Cloud.

18. remove-tag-from-entity

Remove tag from an entity in Confluent Cloud.

19. add-tags-to-topic

Assign existing tags to Kafka topics in Confluent Cloud.

20. list-tags

Retrieve all tags with definitions from Confluent Cloud Schema Registry.

21. alter-topic-config

Alter topic configuration in Confluent Cloud.

22. list-clusters

Get all clusters in the Confluent Cloud environment.

23. list-environments

Get all environments in Confluent Cloud with pagination support.

24. read-environment

Get details of a specific environment by ID.

25. list-schemas

List all schemas in the Schema Registry.

26. get-topic-config

Retrieve configuration details for a specific Kafka topic.

27. create-tableflow-topic

Make a request to create a tableflow topic.

28. list-tableflow-regions

Retrieve a sorted, filtered, paginated list of all tableflow regions.

29. list-tableflow-topics

Retrieve a sorted, filtered, paginated list of all tableflow topics.

30. read-tableflow-topic

Make a request to read a tableflow topic.

31. update-tableflow-topic

Make a request to update a tableflow topic.

32. delete-tableflow-topic

Make a request to delete a tableflow topic.

33. create-tableflow-catalog-integration

Make a request to create a catalog integration.

34. list-tableflow-catalog-integrations

Retrieve a sorted, filtered, paginated list of all catalog integrations.

35. read-tableflow-catalog-integration

Make a request to read a catalog integration.

36. update-tableflow-catalog-integration

Make a request to update a catalog integration.

37. delete-tableflow-catalog-integration

Make a request to delete a tableflow catalog integration.

Open Graph image for mcp-confluent

JSON Config

{
  "mcpServers": {
    "confluent": {
      "command": "node",
      "args": [
        "/path/to/confluent-mcp-server/dist/index.js",
        "--env-file",
        "/path/to/confluent-mcp-server/.env"
      ]
    }
  }
}

Useful Links

Information

Categories