CtrlK
BlogDocsLog inGet started
Tessl Logo

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. Supports JSON_SR, Avro, and Protobuf formats. Handles schemaless topics (plain JSON without SR) and multi-event topics. This skill handles the complete workflow from database to Iceberg/Delta tables. Use this skill when users want to capture database changes and materialize them into Iceberg or Delta Lake tables via Confluent Cloud Tableflow. Trigger phrases include "CDC to Tableflow", "database to Iceberg", "database to Delta Lake", "stream database changes to data lake", "set up Tableflow pipeline", "schemaless topic to Tableflow", or "multi-event topic to Iceberg". Do NOT trigger for general CDC, Debezium, or database replication requests that do not involve Tableflow or Iceberg/Delta Lake as the destination.

72

Quality

88%

Does it follow best practices?

Impact

No eval scenarios have been run

SecuritybySnyk

Passed

No known issues

SKILL.md
Quality
Evals
Security

Quality

Discovery

100%

Based on the skill's description, can an agent find and select it at the right time? Clear, specific descriptions lead to better discovery.

This is an excellent skill description that thoroughly covers specific capabilities, provides rich natural trigger terms, explicitly addresses both what and when, and includes negative trigger guidance to minimize conflicts. The description is detailed yet focused, covering the complete pipeline scope (database to Iceberg/Delta) while clearly delineating its boundaries from general CDC skills.

DimensionReasoningScore

Specificity

Lists multiple specific concrete actions: setting up CDC pipelines, using Debezium source connectors, Flink for transformation, Tableflow for data lake integration, handling schemaless topics, multi-event topics, and supporting specific formats (JSON_SR, Avro, Protobuf). Very detailed and actionable.

3 / 3

Completeness

Clearly answers both 'what' (set up end-to-end CDC pipelines with Debezium, Flink, Tableflow, supporting multiple formats and topic types) and 'when' (explicit 'Use this skill when...' clause plus enumerated trigger phrases and explicit exclusion criteria).

3 / 3

Trigger Term Quality

Excellent coverage of natural trigger phrases including 'CDC to Tableflow', 'database to Iceberg', 'database to Delta Lake', 'stream database changes to data lake', 'schemaless topic to Tableflow', and 'multi-event topic to Iceberg'. These are terms users would naturally use. Also includes negative triggers to reduce false matches.

3 / 3

Distinctiveness Conflict Risk

Highly distinctive with a clear niche: CDC pipelines specifically targeting Confluent Cloud Tableflow with Iceberg/Delta Lake destinations. The explicit 'Do NOT trigger' clause for general CDC/Debezium requests further reduces conflict risk with related but different skills.

3 / 3

Total

12

/

12

Passed

Implementation

77%

Reviews the quality of instructions and guidance provided to agents. Good implementation is clear, handles edge cases, and produces reliable results.

This is a strong, highly actionable skill for a complex multi-component pipeline setup. Its greatest strengths are the critical architecture rules (especially the 'never enable Tableflow directly on CDC topics' warning with clear explanation), the concrete MCP tool calls and CLI fallbacks, and the thorough verification workflow with explicit checkpoints. Its main weakness is length—significant detail that is already delegated to reference files is also repeated inline, and some sections (like the full Oracle prerequisites and DynamoDB patterns) could be more aggressively pushed to references to improve conciseness.

Suggestions

Move the detailed DynamoDB CDC Flink pattern, Oracle XStream prerequisites, and CLI fallback command examples into their respective reference files (connector-configs.md, database-prerequisites.md) and keep only brief summaries with pointers in the main SKILL.md.

Trim the Phase 0 CLI fallback section to just 2-3 representative commands with a note to 'mirror the MCP workflow using CLI equivalents' rather than listing every possible CLI command.

DimensionReasoningScore

Conciseness

The skill is quite long (~400+ lines) and includes some information Claude already knows (e.g., what CDC is, what Debezium does). However, most content is domain-specific operational knowledge (architecture rules, gotchas, MCP tool patterns) that Claude wouldn't inherently know. Some sections could be tightened—the CLI fallback examples and multiple verification approaches add bulk—but the critical architecture rules and gotchas earn their place.

2 / 3

Actionability

The skill provides fully concrete, executable guidance throughout: specific MCP tool calls with parameter names, complete Flink SQL statements, CLI commands with flags, connector configuration patterns, and exact verification steps. The troubleshooting table maps symptoms to specific fixes. Code examples are copy-paste ready with clear placeholder conventions.

3 / 3

Workflow Clarity

The 5-phase workflow is clearly sequenced with explicit validation checkpoints at every stage: verify MCP availability before proceeding, check connector tasks before Flink, verify schemas before expecting auto-discovery, confirm Flink job is RUNNING before enabling Tableflow, and end-to-end verification with a test INSERT. The cleanup order is explicitly numbered. Feedback loops are present (wait and retry patterns, error recovery guidance).

3 / 3

Progressive Disclosure

The skill references 5 separate reference files (database-prerequisites.md, connector-configs.md, flink-sql-patterns.md, troubleshooting.md, rest-api.md) which is good structure, but no bundle files were provided to verify they exist. The main SKILL.md itself is quite long and includes substantial inline detail (e.g., full DynamoDB patterns, Oracle prerequisites, CLI fallback examples) that could have been pushed to the reference files. The references section at the bottom is clean but the body retains too much detail that belongs in those referenced files.

2 / 3

Total

10

/

12

Passed

Validation

90%

Checks the skill against the spec for correct structure and formatting. All validation checks must pass before discovery and implementation can be scored.

Validation10 / 11 Passed

Validation for skill structure

CriteriaDescriptionResult

skill_md_line_count

SKILL.md is long (521 lines); consider splitting into references/ and linking

Warning

Total

10

/

11

Passed

Repository
confluentinc/agent-skills
Reviewed

Table of Contents

Is this your skill?

If you maintain this skill, you can claim it as your own. Once claimed, you can manage eval scenarios, bundle related skills, attach documentation or rules, and ensure cross-agent compatibility.