Confluent Cloud Flink Sql
by confluentinc914d95eff7ffNo license58 starsListed Oct 8, 2026Updated Oct 8, 2026Repository updated 2 days ago
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 to check or debug Flink SQL whose runtime is Confluent Cloud. Also trigger when a Flink SQL question is posed and nothing establishes an Apache Flink OSS runtime. Do NOT trigger for: building or deploying Flink UDFs in Java (UDF/UDTF/PTF — use flink-udf); a full CDC pipeline from a database through Flink into Tableflow/Iceberg/Delta Lake (use confluent-cloud-cdc-tableflow); Kafka Streams topology work (use kafka-streams-programming); or Flink SQL confirmed to run on Apache Flink OSS, not Confluent Cloud.
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-confluent-cloud-flink-sql/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-confluent-cloud-flink-sqlAdd --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-cloud-flink-sqlSource and attribution
Source:confluentinc/agent-skillsinskills/confluent-cloud-flink-sqlat 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.
Leaky Data
confluentinc
Generates a Flink SQL statement that joins an orders stream with a customers table to emit an enriched topic on Confluent Cloud.
Inlined Refs
confluentinc
Guides selection of a Kafka consumer group lag exporter and sets up a Grafana dashboard and lag alerts.
More in Software Development
Playground
anthropics
Builds self-contained interactive HTML playgrounds with controls, live preview, and copyable prompt output.
M5 Onboard
anthropics
Provisions M5Stack ESP32 boards by detecting them on USB, flashing UIFlow 2.0 firmware, and installing a MicroPython app bundle.
Cardputer Buddy
anthropics
Guides iterating on a Cardputer-Adv MicroPython app bundle: adding apps, pushing files over USB-serial, tailing logs, and running REPL commands.
Testing Strategy
anthropics
Designs test strategies and test plans, covering test types, coverage targets, and example test cases.
Tech Debt
anthropics
Identifies, categorizes, and prioritizes technical debt, producing a scored backlog and phased remediation plan.
System Design
anthropics
Guides system and architecture design through requirements, high-level design, deep dives, scaling, and trade-off analysis.