Confluent Skill Creator

---
name: confluent-skill-creator
description: Create Confluent-specific skills for external users. Use this skill when users want to create, build, or author a new skill related to Confluent Cloud, Confluent Platform, Apache Kafka, WarpStream, Flink, Connectors, Schema Registry, Tableflow, CDC pipelines, or any Confluent product. Skills can be use-case focused (like data enrichment, CDC to Tableflow, stream processing workflows) or component-specific (like a Flink skill, Schema Registry skill, or Connector skill). Do NOT use this skill when users want to directly use Confluent products (e.g., build a pipeline, write a producer, deploy Flink SQL) — use the appropriate product-specific skill instead. This skill is specifically for creating new skills, not for using existing ones.
compatibility: Requires Python 3.9+, confluent-kafka, fastavro, requests. Needs access to a Confluent environment (Cloud, Platform, local Docker, or WarpStream) for E2E testing.
metadata:
  author: confluent
  version: "1.0.0"
  last_updated: "2026-05-12"
---

# Confluent Skill Creator

A specialized skill creator for building Confluent product skills that are tested against real Confluent environments (local, platform, cloud, or WarpStream).

This skill extends the base skill-creator workflow with Confluent-specific requirements:
- **Flexible scope**: Skills can be use-case focused (e.g., "CDC from PostgreSQL to Iceberg") or component-specific (e.g., "Flink SQL skill", "Schema Registry skill")
- **Platform targeting**: Skills either target a specific platform (named in the skill) or support all platforms with platform-specific reference files
- **Environment testing**: Real E2E tests against local Confluent, Confluent Platform, Confluent Cloud, or WarpStream
- **Safe CRUD operations**: Show full plan and get confirmation before creating/modifying Confluent resources
- **Credential management**: Proper .env file setup for all required credentials
- **Spec compliance**: Created skills validated against the [Agent Skills specification](https://agentskills.io/specification)
- **Smart defaults**: Schema Registry with JSON_SR (schema GUID in header) by default

## When to use this skill