.fyi
SkillsMCPPluginsSubagents

Browse by category

DevOps & CI/CD SkillsProductivity & Workflow SkillsOther SkillsProduct & Project Management SkillsDocumentation & Knowledge SkillsCode Review & Refactor SkillsBackend & APIs SkillsAgent Meta & Communication SkillsResearch SkillsSecurity SkillsUX UI & Design SkillsTesting & QA SkillsSee all →

Every Claude Code skill, MCP server, plugin and subagent in one directory. Searchable, comparable, and one command from installed. Live stats from GitHub, npm and PyPI.

We're on Product HuntYour agent's app storeCheck it out →
Agent SkillsMCP ServersPluginsSubagentsCoding Agents
CollectionsOfficial publishersGlossaryFAQBlogSearchSavedFeedback
PrivacyTermsllms.txtSitemap

made with ♥ · © 2026 aaaa.fyi

Independent project · real data from public registries

…/kilo-marketplace/cdc-streaming-pipeline
home/skills/kilo-org/kilo-marketplace/cdc-streaming-pipeline
kilo-org avatar

cdc-streaming-pipeline

bykilo-org· 59 skills

Installs

6

Stars

163

Forks

106

Category

Data Science & Analytics

View on GitHub

TL;DR

Build a real-time change-data-capture pipeline from a transactional database (Aurora DSQL, Aurora Postgres, RDS) to Redshift Serverless, S3, or any other sink, via Kinesis Data Streams (or MSK). Covers producer setup, consumer Lambda correctness, the append-only event log + reconstruction pattern, schema-drift handling with SUPER + JSON_PARSE, and the operational gotchas (Redshift Data API parameter caps, async statement polling, poison-record handling, retry-and-bisect). Use when the user asks for "CDC to Redshift", "stream change data capture", "Aurora CDC", "DSQL CDC", "Postgres replication to S3", or "build a Lambda consumer for Kinesis CDC". Aurora DSQL public-preview specifics are flagged; the rest is source-agnostic.

How to install cdc-streaming-pipeline?

kilo-org/kilo-marketplace/cdc-streaming-pipeline
$npx -y skills add kilo-org/kilo-marketplace --skill cdc-streaming-pipeline

Installs into the current project.

›Prefer a prompt? Paste this to your agent

Use this skill

Run `npx skills use "https://github.com/kilo-org/kilo-marketplace" --skill "kilo-org/kilo-marketplace/cdc-streaming-pipeline"` and follow the generated skill instructions now. Read its complete output, redirecting it to a temporary file first if necessary. Resolve relative paths from the supporting-files directory it provides.

Use the whole pack

Use the skills in "https://github.com/kilo-org/kilo-marketplace" that are relevant to the current task. Run `npx skills add "https://github.com/kilo-org/kilo-marketplace"` and select the relevant skills, then follow their instructions.

Preview

kilo-org/kilo-marketplacekilo-org/kilo-marketplace

$ npx -y skills add kilo-org/kilo-marketplace --skill cdc-streaming-pipeline

▸ installing to .claude/skills…

✓ cdc-streaming-pipeline ready

Repokilo-org/kilo-marketplace
TypeSkills
CategoryData Science & Analytics
ForAnalystArchitect
UpdatedJul 2026
License—
First seenJul 27, 2026

Tags

Skill

Related

6 picks
Type
  1. microsoft avatarazure-kustoQuery and analyze data in Azure Data Explorer (Kusto/ADX) using KQL for log analytics, telemetry, and time series analysis.SkillsJul 2026484k1.3k
  2. coreyhaines31 avataranalyticsWhen the user wants to set up, improve, or audit analytics tracking and measurement.SkillsJul 202641k42k
  3. firecrawl avatarfirecrawl-dashboard-reportingPull metrics from analytics dashboards and internal web tools with Firecrawl browser.SkillsJun 202630k100
  4. wshobson avatardata-storytellingTransform data into compelling narratives using visualization, context, and persuasive structure.SkillsJul 202613k38k
  5. anthropics avatardata-visualizationCreate effective data visualizations with Python (matplotlib, seaborn, plotly).SkillsJul 202610k23k
  6. caffeinelabs avatarextension-oqlMake a canister's data queryable by the Caffeine Data Intelligence agent.SkillsJul 20268.8k0