AI Agent Skills by Confluent plugin
Confluent skills for streaming apps: Kafka clients, Schema Registry, Flink SQL, CDC and migration from MSK.
- 64 ★ on the repository
- Last commit
- Apache-2.0
Extended access
Why this level
- The skills write code and Terraform and call Confluent Cloud with your credentials.
Install
- Works in
In your terminal, with SkillFoxx CLI
npx skillfoxx add plugins/ai-agent-skills-by-confluentDetects the agents on your machine, shows the access level and pins the version.
Other ways to install
Access and checks
How we reviewExtended accessThe tool runs code or makes network calls and only reads external data.
- The skills write code and Terraform and call Confluent Cloud with your credentials.
This is third-party code. Review the repository files before installing.
What it does
The Confluent set helps an agent build streaming data applications and pipelines. It includes skills for Java and Python Kafka clients with Schema Registry and Avro, JSON Schema or Protobuf serialization, for Kafka Streams, Flink user-defined functions and Flink SQL on Confluent Cloud with 22 dialect differences covered. Separate skills set up CDC pipelines on Confluent Cloud with Debezium connectors, Flink and Tableflow, scan a project for Kafka apps to register schemas with PII tags and ready Terraform, assess a move from AWS MSK to Confluent Cloud and prepare a cloud provider integration. The `confluent-tuning-advisor` skill inspects topic, client and broker settings read-only.
Who it is for. Developers and data engineers building Kafka and Flink applications on Confluent Cloud who hand routine work to an agent.
Good fit when
- A Kafka producer in Python is needed to send profile events to Confluent Cloud.
- A Flink Table API application in Python filters a stream.
- A repository is scanned for Kafka schemas, PII is tagged and Terraform for Schema Registry is prepared.
- A move from AWS MSK to Confluent Cloud is planned with a choice between Cluster Linking and Gateway.
Not a fit when
- You work with a different streaming platform than Confluent.
- You need migration to run automatically with no review of the result.
- The environment may not create Terraform or call the Confluent CLI.
Example request
Create a Python Kafka producer that sends profile update events to Confluent Cloud with Schema Registry.Limitations
Results depend on the model, which is nondeterministic, so code and changes from the skills must be reviewed and tested, especially for production systems. Confluent Cloud needs your account and credentials, and some skills use the Confluent CLI, the Confluent MCP server or the REST API. The MSK migration skill plans and directs you to documentation and the account team for the move itself. In IBM Bob copy a skill into `~/.bob/skills` by hand or it does not load at startup.
How to disable. Remove the plugin with a Claude Code command or the skill folders installed by `npx skills`, and clean the local `.env` or YAML credential files.
FAQ
How do I install the set?
In Claude Code run `/plugin marketplace add confluentinc/agent-skills` and `/plugin install streaming-skills-plugin@confluent-agent-skills`.
How do I pick individual skills?
With `npx skills add confluentinc/agent-skills`, which lets you pick skills and supports most agents.
Which skills exist for Flink?
`flink-udf` for Java functions, `confluent-cloud-flink-sql` for SQL on Confluent Cloud and `confluent-cloud-cdc-tableflow` for CDC pipelines.
What does kafka-schema-registry do?
It finds Kafka apps in a project, extracts schemas from data models, tags PII fields and prepares Terraform for registration plus a migration report.
How do I install in IBM Bob?
Copy the skill into `~/.bob/skills` or it does not load at startup.
Discussion
No questions or reviews yet.
Related
PluginsConfluent MCP server for Kafka: topics, messages, Flink SQL, Schema Registry and connectors
Official Databricks skills guide coding agents through data work, Lakeflow jobs and resource deployment on the platform.
Official Elastic skills for Elasticsearch, Kibana, Observability, Security and Elastic Cloud: ES|QL, indices, dashboards, alert triage
Neo4j skills for agents: Cypher queries, graph modeling, drivers, import, GraphRAG, GDS and Aura provisioning
Databricks Field Engineering's agent kit: an installer for Databricks skills, an MCP server and a visual Builder App
43 skills for healthcare and life sciences: genomics, clinical data, drug discovery, CDISC and claims analytics
README in short
The repository collects Confluent skills for building data streaming applications. Each skill follows best practices for Schema Registry, security and error handling.