Kafka Connect Salesforce Connector (Source and Sink)

The Salesforce Connector integrates Salesforce.com with Apache Kafka® now includes both a sink connector and a source connector.

The Salesforce source connector provides the capability to capture changes from Salesforce.com via Salesforce Streaming API PushTopics or Salesforce Enterprise Messaging Platform Events. PushTopics provide the ability to subscribe to create, update, delete, and undelete events related to Salesforce Objects (SObjects). Platform Events are user defined publish/subscribe events.


The connector dynamically creates PushTopics if needed when the connector is launched. However, Platform Events must be pre-defined and published in Salesforce. More information on defining platform events and publishing platform events is available at Salesforce.com.

The Salesforce sink connector provides the ability to consume Kafka topics and perform the corresponding create, update, delete, and upsert operations on Salesforce SObjects and publishing Platform Events.


The Salesforce SObjects sink connector requires the Kafka records to have the same structure and format as the records output by the PushTopic source connector. Similarly, the Platform Events sink connector requires the Kafka records to have the same structure and format as the records output by the Platform Events source connector.

Install Salesforce Connector

You can install this connector by using the Confluent Hub client (recommended) or you can manually download the ZIP file.

Install Connector Using Confluent Hub

Confluent Hub Client must be installed. This is installed by default with Confluent Platform commercial features.

Navigate to your Confluent Platform installation directory and run this command to install the latest (latest) connector version. The connector must be installed on every machine where Connect will be run.

confluent-hub install confluentinc/kafka-connect-salesforce:latest

You can install a specific version by replacing latest with a version number. For example:

confluent-hub install confluentinc/kafka-connect-salesforce:1.2.0

Install Connector Manually

Download and extract the ZIP file for your connector and then follow the manual connector installation instructions.


This connector is available under the Confluent Software Evaluation License. You can use this connector for a 30-day trial period. If you are a subscriber, please contact Confluent Support at support@confluent.io for more information.

For more information, see License Topic Configuration and salesforce-platform-event-source-connector-license-config.