Camel Kafka Salesforce Sink Connector

[Rajamohamed SheikIbrahim <Ra...@epam.com.INVALID>]

Hello,

I am doing a POC to Kafka to Salesforce Integration.
For which I am using Camel Kafka Salesforce Sink Connector, I did the configuration and its working for CreateSObject, but how can I do it for UpsertSObject because External ID value will come from Kafka Message.

Is it possible to do upsert operation using external ID through REST API?

CamelKafkaSalesforceSink.Properties
camel.component.salesforce.clientId=***********
camel.component.salesforce.clientSecret=***********
camel.sink.endpoint.sObjectName=Account
camel.component.salesforce.sObjectClass=org.apache.camel.salesforce.dto.Account.class
camel.component.salesforce.userName=***********
camel.component.salesforce.password=***************
camel.component.salesforce.loginUrl=https://login.salesforce.com
camel.component.salesforce.authenticationType=USERNAME_PASSWORD
camel.sink.endpoint.sObjectIdValue=Account
name=upsert-account
connector.class = org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkConnector
tasks.max = 1
topics=account
camel.sink.endpoint.sObjectIdName=EXTERN_ID__c
camel.sink.endpoint.sObjectIdValue= ( this value is from Kafka event, Field : Id). How can I set dynamically in property file ?


Below Sample message from Kafka
{"Id":"F_7503002","Languages__pc":"Gmp","LastName":"Ldgkvg","FirstName":"Tsqtw","Salutation":"Mr","BillingStreet":"68 Nbqvr Street","BillingState":"Inmfp","BillingPostalCode":"857197193","BillingCountry":"EFQ"}}

Thanks,
Rajamohamed


CONFIDENTIALITY CAUTION AND DISCLAIMER

This message is intended only for the use of the individual(s) or entity(ies) to which it is addressed and contains information that is legally privileged and confidential. If you are not the intended recipient, or the person responsible for delivering the message to the intended recipient, you are hereby notified that any dissemination, distribution or copying of this communication is strictly prohibited. All unintended recipients are obliged to delete this message and destroy any printed copies.