Send events from MSK to Salesforce using EventBridge Pipes and API Destinations
This pattern shows how to use EventBridge Pipes to send MSK payload data to Salesforce using API Destinations.
The pattern uses an MSK cluster as a source to EventBridge Pipes, a Lambda function to base64 decode the payload and transform data to adhere to the Salesforce schema, and API Destinations as a target to send the payload to Salesforce.
The use case shown here is to create leads in Salesforce using the payload from MSK.
< Back to all patterns
Clone repo
git clone https://github.com/aws-samples/serverless-patterns/cd serverless-patterns/pipes-msk-to-salesforce-apidestinationDeploy
sam deploy --guided --capabilities CAPABILITY_AUTO_EXPAND CAPABILITY_IAMTesting
See the GitHub repo for detailed testing instructions.
Cleanup
Delete the stack:
sam delete.Created by:
