Unresolved include directive in modules/ROOT/pages/_attributes.adoc - include::../_attributes.adoc[]

Salesforce PubSub API Source Connector

Overview

The Salesforce PubSub API Source Connector is designed to stream events from Salesforce to Kafka topics in real-time.

By leveraging the modern gRPC-based Salesforce Pub/Sub API, this connector allows for efficient, high-performance ingestion of Change Data Capture (CDC) events, Platform Events, and Real-Time Event Monitoring data. It provides a robust alternative to older Streaming API (CometD) based connectors, offering better scalability and a unified eventing interface.

Features

  • Stream real-time events from Salesforce to Kafka

  • Support for multiple Salesforce event types:

    • Change Data Capture (CDC)

    • Platform Events

    • Real-Time Event Monitoring

  • Built on Salesforce Pub/Sub API (gRPC) for high throughput and low latency

  • Converts Salesforce schemas to Kafka Connect schemas, allowing the use of structured converters

  • Support for "at-least-once" delivery semantics

  • Secure authentication using OAuth 2.0 JWT Bearer flow