streaming-skills-plugin

Skills

17 in the Claude listing

• Bad_FrontmatterHelps with stuff.
• Confluent cloud cdc tableflowSet 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.
• Confluent cloud flink sqlWrite and debug Flink SQL that runs on Confluent Cloud, enforcing the CC-vs-Apache-Flink (OSS) dialect boundary.
• Confluent skill creatorCreate Confluent-specific skills for external users.
• Confluent skill reviewerReview 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.
• Confluent tuning advisorAdvisory-only Kafka tuning for Confluent Cloud or Confluent Platform by priority: latency, throughput, availability, or durability.
• Developing kafka java clientUse 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.
• Developing kafka python clientUse 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-p
• Flink udfBuild and deploy Apache Flink user-defined functions (UDFs) in Java for stream processing over Kafka.
• Good skillGenerate a Confluent Cloud topic creation script with idempotency checks.
• Inlined refsGenerate a Kafka consumer group lag dashboard.
• Kafka schema registryScan 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 roll
• Kafka streams programmingArchitect, build, and debug Kafka Streams apps (JVM-embedded stream processing).
• Leaky dataEnrich a customer-orders stream with loyalty tier using Flink SQL on Confluent Cloud.
• Msk migrationUse this skill to assess and plan a migration from AWS MSK (Managed Streaming for Apache Kafka) to Confluent Cloud.
• Stale expectationsGenerate a Schema Registry compatibility report for Avro schemas in a project.
• Trigger overlapBuild a Confluent Cloud topic provisioning script with retention and compaction.