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¶
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 email@example.com for more information.
For more information, see License Topic Configuration and salesforce-platform-event-source-connector-license-config.