Leveraging MuleSoft as an integration layer, we wove together a tapestry of tech tools. Our arsenal included Salesforce Commerce Cloud and Salesforce CRM for bidirectional customer data updates, Databricks for data lake systems, Salesforce Marketing Cloud for campaign-based marketing emails, and Salesforce OCAPI for customer synchronization. We synchronized data with a third-party loyalty program and order management system to keep track of updates to customer information, such as personal and shipping details.
Initially, we used Salesforce CRM’s “Subscriber Channel Listener” to consume events. But due to volume requirements and CRM’s daily message quota, we shifted to Azure Event Hubs. We allowed the CRM team to authenticate against the event hub with an OAuth 2.0 token, which was followed by a post-call for pushing messages to the event hub. In MuleSoft API, we connected to the hub via Apache Kafka batch listener to process large data batches. We also established comprehensive asynchronous reprocessing with alerting capabilities to ensure data synchronization during system unavailability. Our team utilized Azure data analytics to assist our technical team in analyzing logs. This platform enabled us to conveniently track the flow of events across our APIs using KQL’s native query language.