Category: Database, Data

Salesforce Change Data Capture feature supports near real-time data replication with an event-driven architecture based on Salesforce Event Bus. This event bus can be connected to Kafka as a data producer.

The streaming data stack looks as follows: In Salesforce we need to enable Change Data Capture for Orders.

After downloading the platform, we need to set up the environment variables and the path and then we can start up the platform from command line: From the Control Center web interface we can create our Salesforce Orders topic, in our case it is called salesforce_orders: Then we can create our connectors; first for Salesforce Change Data Capture and then for Snowflake: Salesforce Change Data Capture connecotr requires configuration parameters such as username, password, connected app consumer key and consumer secret.

Salesforce Change Data Capture event-driven mechanism together with Kafka and Snowflake provide a great architecture for these requirements.

Related Articles