Language:JapaneseEnglish

streaming-skills-plugin Claude Code Plugin

Author
Confluent
Category
Development
Topics
Data Engineering & Analytics · AI Agents & AI App Development · Migration & Modernization
First cataloged
2026-08-07 (UTC)
Explanation last updated
2026-08-07 (UTC)
Source (GitHub) last updated
2026-07-22 (UTC) (16 days ago)

The explanation below is AI-generated. Please verify it against the sources.

streaming-skills-plugin is a Claude plugin published by Confluent that bundles a set of skills for building data streaming applications with Kafka and Flink. According to its README, the skills guide developers through scaffolding Kafka producers/consumers in Java or Python, building Flink user-defined functions, designing Kafka Streams topologies, setting up CDC pipelines, and registering schemas with Confluent Schema Registry. It also includes skills for planning a migration from AWS MSK to Confluent Cloud and for creating or reviewing additional skills within the same repository. The README notes that skill behavior depends on the underlying language model and can be nondeterministic, so generated code should be reviewed and tested before production use.

About the service

Confluent is the company behind Apache Kafka-based data streaming products, offered as Confluent Cloud (a managed cloud service), Confluent Platform (self-managed deployment), and WarpStream (a Kafka-compatible service for private cloud use). It also provides Schema Registry, part of its Stream Governance offering, which manages schema formats such as Avro, Protobuf, and JSON Schema. Several skills in this plugin are built to scaffold code and pipelines that target these Confluent services or migrate workloads such as AWS MSK into them.

What you can do with streaming-skills-plugin

  • Architect, generate, and debug Kafka Streams applications, including topology design and troubleshooting of issues like rebalancing loops
  • Scan a codebase to extract schemas, tag PII fields, and generate Terraform for Confluent Schema Registry migration
  • Set up CDC pipelines using Debezium source connectors, Flink transformations, and Tableflow into Iceberg or Delta Lake tables
  • Create new Confluent-specific skills or audit existing skills against repository conventions

Sources

History of streaming-skills-plugin

  • Claude Code Plugin Added streaming-skills-plugin

Back to list