streaming-skills-plugin

Partner, reviewed

Skills for streaming application developers, covering Kafka and Flink client libraries and Schema Registry

Plugin · by confluentinc · runs in Claude Code, Cowork, claude.ai · 17 skills · listed 2026-08-07

Claude Code

claude plugin install streaming-skills-plugin

Source

Skills (17)

Skill Bad_Frontmatter

Helps with stuff.

Any agent

npx skills add confluentinc/agent-skills --skill Bad_Frontmatter

Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill confluent-cloud-cdc-tableflow
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill confluent-cloud-flink-sql
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill confluent-skill-creator
```
Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill confluent-skill-reviewer
```
Skill confluent-tuning-advisor

Advisory-only Kafka tuning for Confluent Cloud or Confluent Platform by priority: latency, throughput, availability, or durability.

Any agent
```
npx skills add confluentinc/agent-skills --skill confluent-tuning-advisor
```
Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill developing-kafka-java-client
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill developing-kafka-python-client
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill flink-udf
```
Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill good-skill
```
Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill inlined-refs
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill kafka-schema-registry
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill kafka-streams-programming
```
Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill leaky-data
```
Skill 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"…

Any agent
```
npx skills add confluentinc/agent-skills --skill msk-migration
```
Skill 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.

Any agent
```
npx skills add confluentinc/agent-skills --skill stale-expectations
```
Skill 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…

Any agent
```
npx skills add confluentinc/agent-skills --skill trigger-overlap
```

From Anthropic's public plugin directory, read on 2026-10-15. Find a skill by task.