Salesforce Streaming Event Connector supports the Salesforce Streaming API. You can configure an event source in a Salesforce Streaming Event connection to subscribe to Salesforce platform events, PushTopic queries, and change events. You can use the event source in a process to consume changes in near real time.
After you define an event source for a Salesforce Streaming Event connection, you can publish the connection on the Cloud Server. You can then access the event source in a process and deploy the process on the Cloud Server to consume the events generated by the event source downstream.
After the connection is published for the first time, Salesforce Streaming Event connector assigns a default replay ID of -1. When the event is delivered to the subscribers, the replay ID is auto-generated based on the position of the event in the event stream. The Process Server persists the replay IDs and uses them to process subsequent requests. In case of a connection failure, the Process Server uses the persisted replay ID to retrieve missed events and avoid message loss.
Salesforce retains messages for 24 hours. If the replay ID points to a message older than 24 hours, the replay ID is reset to -1 and only the recent events are processed. To facilitate at-most once delivery, the Informatica Cloud Server uses an idempotent repository to store the replay ID, thereby avoiding duplicate processing when the replay ID is reset.
To create event sources for a Salesforce connection, click Add Event Source on the Event Sources tab. Select the event source type as Event Source. You can add one or more event sources for each Salesforce connection that you create.
The following table describes the basic event source properties that you can configure:
Property
Description
Name
Required. The event source name that appears in the Process Designer. The name must be unique for the connection.
The name must start with an alphabet and can contain only alphabets, numbers, or hyphens (-).
Description
Optional. A description for the Salesforce event source that appears in the Process Designer.
Enabled
Select Yes to make the event source available immediately after it is published.
Select No to disable the event source until you are ready to use it.
Default is Yes.
You can configure the following properties for an event source:
Event Consumer
Required. Name of the Salesforce platform event, PushTopic query, or change event that you want to subscribe to.
Use one of the following ways to configure the property based on the type of event that you want to subscribe to:
Subscribing to Salesforce platform events
To subscribe to platform events, enter the API name that you defined for the platform event in Salesforce, prefixed by the term /event/.
For example, consider a Salesforce platform event with the API name set to CS_PlatformEvent_e as shown in the following image:
For this Salesforce platform event, enter the following value in the Event Consumer field:
/event/CS_PlatformEvent_e
Subscribing to Salesforce PushTopic queries
To subscribe to PushTopic queries, enter the streaming push topic name that you defined for the PushTopic query in Salesforce Streaming Event, prefixed by the term /topic/.
For example, consider a Salesforce PushTopic query with the push topic name set to AccountTopic as shown in the following image:
For this Salesforce PushTopic query, enter the following value in the Event Consumer field:
/topic/AccountTopic
Subscribing to change events
You can use Salesforce Streaming Event Connector to subscribe to change events in Salesforce and synchronize the corresponding data in an external data store.
Change events represent the changes that have been made to a record. Changes include creating a new record, updating an existing record, deleting a record, and undeleting a record.
To subscribe to change events, use one of the following formats:
▪ /data/ChangeEvents to subscribe to the change events of all the Salesforce CDC-enabled entities
▪ /data/<standard_object_name>ChangeEvent to subscribe to the change events of a specific standard object
▪ /data/<custom_object_name>__ChangeEvent to subscribe to the change events of a specific custom object
If you update the list of CDC-enabled entities in Salesforce, you must republish the Salesforce connection and process to listen to the new or updated CDC-enabled entities.
By default, Salesforce Streaming Event Connector listens to all the change events of all the entities in an organization that are enabled for Change Data Capture (CDC) in Salesforce. To filter the change events, you can define specific CDC-enabled entities that you want to listen to in the Event Filter field.
Event Filter
In the Event Filter field, enter a comma-separated list of names of the CDC-enabled entities for which you want to filter the change events.
You can view the status of each event source in the published connection. If the status of the event source is stopped, you can republish the connection and restart the event source. When you republish the connection, all the event sources in the connection start by default.
For more information about starting and stopping event sources in a listener-based connection, see Connectors for Cloud Application Integration and Monitor.
