agent-skills

In the author's own words, from each skill's SKILL.md.

• confluent-cloud-cdc-tableflow

  Set up end-to-end Change Data Capture (CDC) pipelines on Confluent Cloud using Debezium source connectors, Flink for transformation, and Tableflow for data lake integration. Supports JSON_SR, Avro, and Protobuf formats. Handles schemaless topics (plain JSON without SR) and multi-event topics. This skill handles the complete workflow from database to Iceberg/Delta tables. Use this skill when users…

  skills/confluent-cloud-cdc-tableflow/SKILL.md on GitHub (opens in a new tab)

• confluent-cloud-flink-sql

  Write and debug Flink SQL that runs on Confluent Cloud, enforcing the CC-vs-Apache-Flink (OSS) dialect boundary. Use when the working directory is a Confluent Cloud Flink workspace, when a Flink SQL statement needs checking before it runs on a CC compute pool, or when the user mentions CC Flink, Confluent Cloud Flink SQL, the `confluent flink` CLI, a CFU compute pool, `CREATE CONNECTION`, or asks…

  skills/confluent-cloud-flink-sql/SKILL.md on GitHub (opens in a new tab)

• confluent-skill-creator

  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…

  skills/confluent-skill-creator/SKILL.md on GitHub (opens in a new tab)

• confluent-skill-reviewer

  Review a Confluent agent skill in this repo against the Agent Skills spec (agentskills.io), Confluent conventions in CLAUDE.md, the PR template gates, and the evals-as-contract rule. Use this skill whenever the user asks to review, audit, validate, or lint a skill; opens or inspects a PR that adds or modifies anything under `skills/`; asks about spec conformance, lazy-loading, frontmatter shape,…

  skills/confluent-skill-reviewer/SKILL.md on GitHub (opens in a new tab)

• confluent-tuning-advisor

  Advisory-only Kafka tuning for Confluent Cloud or Confluent Platform by priority: latency, throughput, availability, or durability. Use when asked to size a planned topic or tune an existing cluster, topic, producer, or consumer for a quantified target such as lower p99 latency or no lost acknowledged writes. Inspects configuration read-only and recommends changes, trade-offs, and validation; the…

  skills/confluent-tuning-advisor/SKILL.md on GitHub (opens in a new tab)

• developing-kafka-java-client

  Use when the user wants to integrate a Kafka client into an existing application or scaffold a Java Kafka client project (Maven or Gradle based) for Confluent Cloud, local Docker, or WarpStream. Covers the Apache Kafka Java clients (KafkaProducer/KafkaConsumer/KafkaShareConsumer) with Avro, JSON Schema, or Protobuf serializers. Also use when the user wants to optimize Java Kafka client configurat…

  skills/developing-kafka-java-client/SKILL.md on GitHub (opens in a new tab)

• developing-kafka-python-client

  Use when the user wants to build a Python Kafka producer or consumer, add Schema Registry to existing Python code, migrate from raw JSON to schema-backed serialization, or scaffold a confluent-kafka-python project for Confluent Cloud, local Docker, or WarpStream. Also use when user wants to optimize Python Kafka client configuration for WarpStream.

  skills/developing-kafka-python-client/SKILL.md on GitHub (opens in a new tab)

• flink-udf

  Build and deploy Apache Flink user-defined functions (UDFs) in Java for stream processing over Kafka. Use this skill when users want to create scalar UDFs, user-defined table functions (UDTFs), or process table functions (PTFs) in Java, deploy them to Confluent Cloud or local Docker environments, and invoke them from Flink SQL or the Table API. Trigger on: Flink UDF, custom Flink function, proces…

  skills/flink-udf/SKILL.md on GitHub (opens in a new tab)

• kafka-schema-registry

  Scan a project to identify Kafka applications, extract schemas from data models, tag PII fields, generate Terraform for Confluent Schema Registry registration, and produce a migration report with rollout ordering. Use this skill when a user asks to analyze a folder or repo for Kafka usage, extract schemas, audit producer/consumer configurations, or generate Terraform for Schema Registry.

  skills/kafka-schema-registry/SKILL.md on GitHub (opens in a new tab)

• kafka-streams-programming

  Architect, build, and debug Kafka Streams apps (JVM-embedded stream processing). Use when user mentions KStream, KTable, topology, TopologyTestDriver, StreamsBuilder, interactive queries, GlobalKTable, joins/windows/aggregations, or debugging issues (rebalancing, state stores, lag, deserialization errors). Also use when user wants to optimize Kafka Streams for WarpStream or tune Kafka Streams cli…

  skills/kafka-streams-programming/SKILL.md on GitHub (opens in a new tab)

• msk-migration

  Use this skill to assess and plan a migration from AWS MSK (Managed Streaming for Apache Kafka) to Confluent Cloud. Triggers on user intent like "migrate MSK to Confluent Cloud", "move off MSK", "MSK to CC cutover", "Zero-Cut migration from MSK", "kcp scan my MSK", or any discussion of MSK-to-CC assessment, planning, cluster sizing, Cluster Linking setup, Gateway-based switchover, or post-cutover…

  skills/msk-migration/SKILL.md on GitHub (opens in a new tab)

• Bad_Frontmatter

  Helps with stuff.

  skills/confluent-skill-reviewer/evals/mock-skills/bad-frontmatter/SKILL.md on GitHub (opens in a new tab)

• good-skill

  Generate a Confluent Cloud topic creation script with idempotency checks. Use when the user asks to create a topic, provision topics, or write a `create-topics.sh` for Confluent Cloud. Do NOT trigger for self-managed Apache Kafka, schema registration, Terraform generation, or Kafka Streams topology authoring.

  skills/confluent-skill-reviewer/evals/mock-skills/good-skill/SKILL.md on GitHub (opens in a new tab)

• inlined-refs

  Generate a Kafka consumer group lag dashboard. Use when the user asks to monitor lag, build a dashboard for consumer lag, or wire up Prometheus exporters for Kafka. Do NOT trigger for producer metrics, broker JMX, or Streams-specific monitoring.

  skills/confluent-skill-reviewer/evals/mock-skills/inlined-refs/SKILL.md on GitHub (opens in a new tab)

• leaky-data

  Enrich a customer-orders stream with loyalty tier using Flink SQL on Confluent Cloud. Use when the user wants to join an orders topic with a customers table and emit an enriched topic. Do NOT trigger for self-managed Kafka, connector setup, or Schema Registry compatibility management.

  skills/confluent-skill-reviewer/evals/mock-skills/leaky-data/SKILL.md on GitHub (opens in a new tab)

• stale-expectations

  Generate a Schema Registry compatibility report for Avro schemas in a project. Use when the user asks to check Avro compatibility, validate schema evolution, or report breaking changes. Do NOT trigger for Protobuf, JSON Schema, or Kafka client code generation.

  skills/confluent-skill-reviewer/evals/mock-skills/stale-expectations/SKILL.md on GitHub (opens in a new tab)

• trigger-overlap

  Build a Confluent Cloud topic provisioning script with retention and compaction. Use when the user asks to create a topic, write a `create-topics.sh`, set retention, set compaction policy, provision topics for Confluent Cloud, or generate idempotent topic scripts.

  skills/confluent-skill-reviewer/evals/mock-skills/trigger-overlap/SKILL.md on GitHub (opens in a new tab)

No skill matches that filter.

Similar skills

• superpowersby obra An agentic skills framework & software development methodology that works. 300k stars · 15 skills
• uiby shadcn-ui Composable, accessible components with thoughtful defaults. Build your own component library with code you can customize, extend, and make… 126k stars · 2 skills
• cavemanby JuliusBrussee 🪨 why use many token when few token do trick. Viral skill + proxy for coding agents that cuts 65% of tokens by talking like a caveman. 113k stars · 20 skills
• claude-memby thedotmack Persistent Context Across Sessions for Every Agent – Captures everything your agent does during sessions, compresses it with AI, and inject… 101k stars · 20 skills
• oh-my-openagentby code-yeongyu OmO: Just type "mass ulw" keyword with your prompt. Now you are the master of graph engineering. 70.1k stars · 25 skills
• OpenMontageby calesthio World's first open-source, agentic video production system. 12 production pipelines, 100+ tools, 700+ agent skill and production-knowledge… 68.6k stars · 30 skills