Red Hat Camel K is no longer supported.
As of June 30, 2025, Red Hat build of Camel K has reached End of Life. The suggested replacements is Red Hat build of Apache Camel. For details about moving, see the Camel K to Camel Quarkus migration guide.Chapter 62. Salesforce Update Sink
Updates an object in Salesforce. The body received must contain a JSON key-value pair for each property to update and sObjectName and sObjectId must be provided as parameters.
Example of key-value pair: { "Phone": "1234567890", "Name": "Antonia" }
62.1. Configuration Options Copy linkLink copied to clipboard!
The following table summarizes the configuration options available for the salesforce-update-sink Kamelet:
| Property | Name | Description | Type | Default | Example |
|---|---|---|---|---|---|
| clientId * | Consumer Key | The Salesforce application consumer key | string | ||
| clientSecret * | Consumer Secret | The Salesforce application consumer secret | string | ||
| password * | Password | The Salesforce user password | string | ||
| sObjectId * | Object Id | Id of the object. Only required if using key-value pair. | string | ||
| sObjectName * | Object Name | Type of the object. Only required if using key-value pair. | string |
| |
| userName * | Username | The Salesforce username | string | ||
| loginUrl | Login URL | The Salesforce instance login URL | string |
|
Fields marked with an asterisk (*) are mandatory.
62.2. Dependencies Copy linkLink copied to clipboard!
At runtime, the salesforce-update-sink Kamelet relies upon the presence of the following dependencies:
- camel:salesforce
- camel:kamelet
62.3. Usage Copy linkLink copied to clipboard!
This section describes how you can use the salesforce-update-sink.
62.3.1. Knative Sink Copy linkLink copied to clipboard!
You can use the salesforce-update-sink Kamelet as a Knative sink by binding it to a Knative object.
salesforce-update-sink-binding.yaml
62.3.1.1. Prerequisite Copy linkLink copied to clipboard!
Make sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.
62.3.1.2. Procedure for using the cluster CLI Copy linkLink copied to clipboard!
-
Save the
salesforce-update-sink-binding.yamlfile to your local drive, and then edit it as needed for your configuration. Run the sink by using the following command:
oc apply -f salesforce-update-sink-binding.yaml
oc apply -f salesforce-update-sink-binding.yamlCopy to Clipboard Copied! Toggle word wrap Toggle overflow
62.3.1.3. Procedure for using the Kamel CLI Copy linkLink copied to clipboard!
Configure and run the sink by using the following command:
kamel bind channel:mychannel salesforce-update-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.sObjectId=The Object Id" -p "sink.sObjectName=Contact" -p "sink.userName=The Username"
kamel bind channel:mychannel salesforce-update-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.sObjectId=The Object Id" -p "sink.sObjectName=Contact" -p "sink.userName=The Username"
This command creates the KameletBinding in the current namespace on the cluster.
62.3.2. Kafka Sink Copy linkLink copied to clipboard!
You can use the salesforce-update-sink Kamelet as a Kafka sink by binding it to a Kafka topic.
salesforce-update-sink-binding.yaml
62.3.2.1. Prerequisites Copy linkLink copied to clipboard!
Ensure that you’ve installed the AMQ Streams operator in your OpenShift cluster and created a topic named my-topic in the current namespace. Make also sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.
62.3.2.2. Procedure for using the cluster CLI Copy linkLink copied to clipboard!
-
Save the
salesforce-update-sink-binding.yamlfile to your local drive, and then edit it as needed for your configuration. Run the sink by using the following command:
oc apply -f salesforce-update-sink-binding.yaml
oc apply -f salesforce-update-sink-binding.yamlCopy to Clipboard Copied! Toggle word wrap Toggle overflow
62.3.2.3. Procedure for using the Kamel CLI Copy linkLink copied to clipboard!
Configure and run the sink by using the following command:
kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic salesforce-update-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.sObjectId=The Object Id" -p "sink.sObjectName=Contact" -p "sink.userName=The Username"
kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic salesforce-update-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.sObjectId=The Object Id" -p "sink.sObjectName=Contact" -p "sink.userName=The Username"
This command creates the KameletBinding in the current namespace on the cluster.
62.4. Kamelet source file Copy linkLink copied to clipboard!
https://github.com/openshift-integration/kamelet-catalog/salesforce-update-sink.kamelet.yaml