Salesforce Streaming Source

Reference Name

No

Required. Name used to uniquely identify this source for lineage, annotating metadata, etc.

Username

Yes

Required. Salesforce username.

Password

Yes

Required. Salesforce password.

Security Token

Yes

Optional. Salesforce security Token. If the password does not contain the security token the plugin will append the token before authenticating with salesforce.

Consumer Key

Yes

Required. Application Consumer Key. This is also known as the OAuth client id. A Salesforce connected application must be created in order to get a consumer key.

Consumer Secret

Yes

Required. Application Consumer Secret. This is also known as the OAuth client secret. A Salesforce connected application must be created in order to get a client secret.

Login Url

Yes

Required. Salesforce OAuth2 login url.

Default is https://login.salesforce.com/services/oauth2/token

Connection Timeout

Yes

1.4.4

Optional. Maximum time in milliseconds to wait for connection initialization before time out.

Default is 30000 milliseconds.

Topic Name

Yes

Required. Salesforce push topic name. Plugin will track updates from this topic. If the topic does not exist, the plugin creates it. To manually create pushTopic use Salesforce workbench, Apex code or API.

Query

Yes

Optional. Salesforce push topic query. The query is used by Salesforce to send updates to push topic. This field not required if you are using an existing push topic.

Notify On Create

No

Required. Push topic property, which specifies if a create operation should generate a record.

Default is Enabled.

Notify On Update

No

Required. Push topic property, which specifies if a update operation should generate a record.

Default is Enabled.

Notify On Delete

No

Required. Push topic property, which specifies if a delete operation should generate a record.

Default is Enabled.

Notify For Fields

No

Required. Push topic property, which specifies how the record is evaluated against the PushTopic query. The Notify For Fields values are:

• All. Notifications are generated for all record field changes, provided the evaluated records match the criteria specified in the WHERE clause.

• Referenced (default). Changes to fields referenced in the SELECT and WHERE clauses are evaluated. Notifications are generated for the evaluated records only if they match the criteria specified in the WHERE clause.

• Select. Changes to fields referenced in the SELECT clause are evaluated. Notifications are generated for the evaluated records only if they match the criteria specified in the WHERE clause. 

• Where. Changes to fields referenced in the WHERE clause are evaluated. Notifications are generated for the evaluated records only if they match the criteria specified in the WHERE clause.

Default is Referenced.

SObject Name

Yes

Optional. Salesforce object name to read. If value is provided, plugin will get all fields for this object from Salesforce and generate SOQL query (select <FIELD_1, FIELD_2, ..., FIELD_N> from ${sObjectName}). Ignored if SOQL query is provided.

_bool

bool

_int

int

_long

long

_double, currency, percent

double

date

date

datetime

timestamp

Microseconds

time

time

Microseconds

picklist

string

multipicklist

string

combobox

string

reference

string

base64

string

textarea

string

phone

string

id

string

url

string

email

string

encryptedstring

string

datacategorygroupreference

string

location

string

address

string

anyType

string

json

string

complexvalue

string