MCP Tool Reference
CONFLUENT KAFKA TOOLS
46 tools from the Confluent Kafka MCP Server, categorised by risk level.
View the Confluent Kafka policy →READ TOOLS
28list-topics List all topics in the Kafka cluster search-topics-by-tag List all topics with the specified tag search-topics-by-name List all topics matching the specified name get-topic-config Retrieve configuration details for a specific Kafka topic list-tags Retrieve all tags with definitions from Schema Registry list-clusters Get all clusters in the Confluent Cloud environment list-environments Get all environments in Confluent Cloud read-environment Get details of a specific environment by ID list-schemas List all schemas in the Schema Registry list-connectors Retrieve a list of active connectors read-connector Get information about a connector consume-messages Consume messages from one or more Kafka topics list-flink-statements Retrieve a list of all Flink statements read-flink-statement Read a Flink statement and its results list-flink-catalogs List all catalogs in the Flink environment list-flink-databases List all databases in a Flink catalog list-flink-tables List all tables in a Flink database describe-flink-table Get full schema details for a Flink table get-flink-table-info Get table metadata via INFORMATION_SCHEMA get-flink-statement-exceptions Retrieve recent exceptions for a Flink statement get-flink-statement-profile Get Query Profiler data with metrics and issue detection check-flink-statement-health Perform aggregate health check for a Flink statement detect-flink-statement-issues Detect issues for a Flink statement list-tableflow-regions List all tableflow regions list-tableflow-topics List all tableflow topics read-tableflow-topic Read a tableflow topic list-tableflow-catalog-integrations List all catalog integrations read-tableflow-catalog-integration Read a catalog integration WRITE TOOLS
11create-topics Create one or more Kafka topics produce-message Produce records to a Kafka topic create-connector Create a new connector create-flink-statement Create a Flink statement create-topic-tags Create new tag definitions in Confluent Cloud add-tags-to-topic Assign existing tags to Kafka topics alter-topic-config Alter topic configuration in Confluent Cloud create-tableflow-topic Create a tableflow topic update-tableflow-topic Update a tableflow topic create-tableflow-catalog-integration Create a catalog integration update-tableflow-catalog-integration Update a catalog integration DESTRUCTIVE TOOLS
7delete-topics Delete topics with the given names delete-connector Delete an existing connector delete-flink-statements Delete a Flink statement delete-tag Delete a tag definition from Confluent Cloud remove-tag-from-entity Remove tag from an entity in Confluent Cloud delete-tableflow-topic Delete a tableflow topic delete-tableflow-catalog-integration Delete a tableflow catalog integration ENFORCE POLICIES ON CONFLUENT KAFKA
Open source. One binary. Zero dependencies.