Leaky Data
by confluentinc914d95eff7ffNo license58 starsListed Oct 8, 2026Updated Oct 8, 2026Repository updated 2 days ago
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.
Add to a SourceWeft workspace
- Open the skill in your dashboard and add it to a workspace.
- Enable it for the chats that should use it.
This skill is instructions only: it ships no scripts to execute.
Add to SourceWeftYou will be asked to sign in first, then taken straight to this skill.
Ask your agent to install it
Paste this prompt into Claude Code, Codex, Cursor or another agent that can run commands — or into SourceWeft chat. The agent reads this skill's install guide, shows you its source, license and scripts, and installs it with the SourceWeft CLI once you agree.
Read https://sourceweft.com/skills/gh-confluentinc-agent-skills-leaky-data/install.md and install the skill it describes. Before installing, show me its source, license and whether it ships scripts, and wait for my OK. Ask me before changing anything else on my machine.Install it yourself from a terminal
For Claude Code, Codex, Cursor and other local agents. The SourceWeft CLI fetches the skill from its source repository at the commit scanned here, and verifies every file against the hashes recorded when the skill was scanned. If anything differs, nothing is written.
npx @sourceweft/cli skills install gh-confluentinc-agent-skills-leaky-dataAdd --agent claude-code, codex, cursor or universal to choose which agent gets it (Claude Code by default).
Upstream installer — not verified by SourceWeft
The open-source skills installer fetches the same pinned commit, but does not check the files against the hashes SourceWeft recorded.
npx skills add https://github.com/confluentinc/agent-skills/tree/914d95eff7ff50513b34bfb9ac97eda7c7fce899/skills/confluent-skill-reviewer/evals/mock-skills/leaky-dataSource and attribution
Source:confluentinc/agent-skillsinskills/confluent-skill-reviewer/evals/mock-skills/leaky-dataat commit914d95e
License: No license
Content belongs to its original authors. SourceWeft indexes it from a public repository.
More from confluentinc/agent-skills
Flink Udf
confluentinc
Guides building and deploying Java Apache Flink user-defined functions (UDFs, UDTFs, PTFs) to Confluent Cloud or local Docker.
Trigger Overlap
confluentinc
Generates a create-topics.sh script for provisioning Confluent Cloud Kafka topics with retention and compaction settings.
Stale Expectations
confluentinc
Scans a project for Avro schemas, checks them against Schema Registry compatibility, and writes a Markdown report.
Inlined Refs
confluentinc
Guides selection of a Kafka consumer group lag exporter and sets up a Grafana dashboard and lag alerts.
Confluent Cloud Flink Sql
confluentinc
Guides writing and debugging Flink SQL for Confluent Cloud, enforcing the CC-versus-Apache-Flink dialect boundary.
More in Data & Analytics
Spanner Basics
Guides Google Cloud Spanner administration, schema design, querying and performance diagnosis.
Gke Cost Analysis
Answers natural-language questions about GKE cluster and workload costs using BigQuery billing exports and live cluster metrics.
Datalineage Bigquery Asset Impact Analysis
Guides an agent through downstream impact (blast radius) analysis for a BigQuery table or view using Data Lineage.
Bigquery Troubleshooting
Diagnoses failing, slow, or unexpectedly expensive BigQuery jobs through structured root-cause workflows.
Bigquery Optimization
Guides BigQuery cost and performance optimization across capacity editions, storage layout, and SQL queries.
Bigquery Bigframes
Guides writing Python code with BigQuery DataFrames (BigFrames) for data processing, analysis, and machine learning.