connect-cdc-salesforce

Streams Salesforce CDC events and Platform Events into Redpanda or Kafka.

6|3|Updated May 31, 2026
One-click install
npx skills add https://github.com/redpanda-data/skills --skill connect-cdc-salesforce
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: connect-cdc-salesforce
Source: https://github.com/redpanda-data/skills/tree/main/skills/connect-cdc-salesforce
Command: npx skills add https://github.com/redpanda-data/skills --skill connect-cdc-salesforce

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

Streams Salesforce Change Data Capture (CDC) events and Platform Events into Redpanda or Kafka via Redpanda Connect, providing a scalable, replayable pipeline that tracks per-topic replay IDs, REST snapshots, and durable state across restarts.

Core Features & Use Cases

  • Per-object CDC and Platform Events routing into dedicated topics
  • Optional REST snapshot of sObjects and per-topic replay-id checkpointing for restart resilience
  • Enterprise-licensed features for Iceberg Topics, Tiered Storage, Cloud Topics, and Server-side Schema Validation
  • Supports mixed pipelines (CDC + Platform Events) and routing patterns to simplify downstream consumption

Quick Start

Configure a Salesforce Connected App, enable CDC for desired sObjects, and point a Redpanda Connect pipeline at this input.

Frequently Asked Questions about connect-cdc-salesforce

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I stream Salesforce CDC events to Kafka?

You can stream Salesforce CDC events to Kafka by configuring a Redpanda Connect pipeline that ingests per-object Change Data Capture data using your Salesforce org URL and OAuth client credentials, routing the output into dedicated Kafka topics.

What is needed to capture Salesforce Platform Events alongside CDC data?

Capturing Salesforce Platform Events alongside CDC data requires a Salesforce Connected App, a set of defined topics, and a durable cache for checkpointing replay IDs to support mixed pipelines and ensure restart resilience.

Can I take a REST snapshot of Salesforce sObjects before streaming CDC changes?

Yes, you can take an optional REST snapshot of Salesforce sObjects before streaming CDC changes. This allows you to initialize topic state and maintain per-topic replay-id checkpointing for downstream consumption.

Do I need a license to use enterprise features for Salesforce CDC pipelines?

Yes, you need an enterprise license to unlock features for Salesforce CDC pipelines, including Iceberg Topics, Tiered Storage, Cloud Topics, and Server-side Schema Validation in Redpanda or Kafka.

How does the pipeline handle Salesforce CDC replay IDs across restarts?

The pipeline tracks Salesforce CDC replay IDs across restarts by using a durable cache for checkpointing. This per-topic state tracking ensures the data stream remains scalable and replayable without losing event progress.