// MCP TOOL REFERENCE

CONFLUENT KAFKA TOOLS

46 tools from the Confluent Kafka MCP Server, categorised by risk level.

// ALL 46 CONFLUENT KAFKA TOOLS

READ 28 tools

Read check-flink-statement-health Perform health check for a Flink statement Read consume-messages Consume messages from Kafka topics Read describe-flink-table Get full schema details for a Flink table Read detect-flink-statement-issues Detect issues for a Flink statement Read get-flink-statement-exceptions Retrieve recent exceptions for a Flink statement Read get-flink-statement-profile Get Query Profiler data with metrics and issues Read get-flink-table-info Get table metadata via INFORMATION_SCHEMA Read get-topic-config Retrieve configuration details for a Kafka topic Read list-clusters Get all clusters in the environment Read list-connectors Retrieve a list of active connectors Read list-environments Get all environments in Confluent Cloud Read list-flink-catalogs List all catalogs in the Flink environment Read list-flink-databases List all databases in a Flink catalog Read list-flink-statements Retrieve a list of all Flink statements Read list-flink-tables List all tables in a Flink database Read list-schemas List all schemas in the Schema Registry Read list-tableflow-catalog-integrations List all catalog integrations Read list-tableflow-regions List all Tableflow regions Read list-tableflow-topics List all Tableflow topics Read list-tags Retrieve all tags from Schema Registry Read list-topics List all topics in the Kafka cluster Read read-connector Get information about a connector Read read-environment Get details of a specific environment Read read-flink-statement Read a Flink statement and its results Read read-tableflow-catalog-integration Read a catalog integration Read read-tableflow-topic Read a Tableflow topic Read search-topics-by-name List all topics matching a name pattern Read search-topics-by-tag List all topics with a specified tag

WRITE 10 tools

Write add-tags-to-topic Assign existing tags to Kafka topics Write alter-topic-config Alter topic configuration in Confluent Cloud Write create-connector Create a new Kafka connector Write create-tableflow-catalog-integration Create a catalog integration Write create-tableflow-topic Create a Tableflow topic Write create-topic-tags Create new tag definitions in Confluent Cloud Write create-topics Create one or more Kafka topics Write produce-message Produce records to a Kafka topic Write update-tableflow-catalog-integration Update a catalog integration Write update-tableflow-topic Update a Tableflow topic

DESTRUCTIVE 7 tools

Destructive delete-connector Delete a Kafka connector Destructive delete-flink-statements Delete a Flink statement Destructive delete-tableflow-catalog-integration Delete a catalog integration Destructive delete-tableflow-topic Delete a Tableflow topic Destructive delete-tag Delete a tag definition from Confluent Cloud Destructive delete-topics Delete Kafka topics and all messages Destructive remove-tag-from-entity Remove a tag from an entity

EXECUTE 1 tools

Execute create-flink-statement Create and run a Flink SQL statement

// RUNNING THIS SERVER

The managed route: connect Confluent Kafka through the PolicyLayer gateway — every tool call above is checked against your policy before it runs, with a full audit log.

DIRECT INSTALL (UNMANAGED) npx -y @@confluentinc/mcp-confluent

// FAQ

How many tools does the Confluent Kafka MCP server have? +

The Confluent Kafka MCP server exposes 46 tools across 4 categories: Read, Write, Destructive, Execute.

How do I enforce policies on Confluent Kafka tools? +

Route the Confluent Kafka server through the PolicyLayer gateway. Define allow, deny, or approval rules per tool in the dashboard — they are enforced on every call before it reaches the server.

What risk categories do Confluent Kafka tools fall into? +

Confluent Kafka tools are categorised as Read (28), Write (10), Destructive (7), Execute (1). Each category has a recommended default policy.

Let agents act without letting them run wild.

Route your MCP servers through PolicyLayer and every tool call is checked against your policy before it runs — allow, deny, or require approval. Per-identity grants. Full audit log. Live in minutes.

SECURE YOUR MCP →

Free to start. No card required.

4,600+ MCP servers and 31,000+ tools scanned and risk-classified.