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.Este conteúdo não está disponível no idioma selecionado.
Chapter 60. Salesforce Create Sink
Creates an object in Salesforce. The body of the message must contain the JSON of the salesforce object.
Example body: { "Phone": "555", "Name": "Antonia", "LastName": "Garcia" }
60.1. Configuration Options Copiar o linkLink copiado para a área de transferência!
The following table summarizes the configuration options available for the salesforce-create-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 | ||
userName * | Username | The Salesforce username | string | ||
loginUrl | Login URL | The Salesforce instance login URL | string |
| |
sObjectName | Object Name | Type of the object | string |
|
Fields marked with an asterisk (*) are mandatory.
60.2. Dependencies Copiar o linkLink copiado para a área de transferência!
At runtime, the salesforce-create-sink
Kamelet relies upon the presence of the following dependencies:
- camel:salesforce
- camel:kamelet
60.3. Usage Copiar o linkLink copiado para a área de transferência!
This section describes how you can use the salesforce-create-sink
.
60.3.1. Knative Sink Copiar o linkLink copiado para a área de transferência!
You can use the salesforce-create-sink
Kamelet as a Knative sink by binding it to a Knative object.
salesforce-create-sink-binding.yaml
60.3.1.1. Prerequisite Copiar o linkLink copiado para a área de transferência!
Make sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.
60.3.1.2. Procedure for using the cluster CLI Copiar o linkLink copiado para a área de transferência!
-
Save the
salesforce-create-sink-binding.yaml
file 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-create-sink-binding.yaml
oc apply -f salesforce-create-sink-binding.yaml
Copy to Clipboard Copied! Toggle word wrap Toggle overflow
60.3.1.3. Procedure for using the Kamel CLI Copiar o linkLink copiado para a área de transferência!
Configure and run the sink by using the following command:
kamel bind channel:mychannel salesforce-create-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.userName=The Username"
kamel bind channel:mychannel salesforce-create-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.userName=The Username"
This command creates the KameletBinding in the current namespace on the cluster.
60.3.2. Kafka Sink Copiar o linkLink copiado para a área de transferência!
You can use the salesforce-create-sink
Kamelet as a Kafka sink by binding it to a Kafka topic.
salesforce-create-sink-binding.yaml
60.3.2.1. Prerequisites Copiar o linkLink copiado para a área de transferência!
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.
60.3.2.2. Procedure for using the cluster CLI Copiar o linkLink copiado para a área de transferência!
-
Save the
salesforce-create-sink-binding.yaml
file 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-create-sink-binding.yaml
oc apply -f salesforce-create-sink-binding.yaml
Copy to Clipboard Copied! Toggle word wrap Toggle overflow
60.3.2.3. Procedure for using the Kamel CLI Copiar o linkLink copiado para a área de transferência!
Configure and run the sink by using the following command:
kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic salesforce-create-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.userName=The Username"
kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic salesforce-create-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.userName=The Username"
This command creates the KameletBinding in the current namespace on the cluster.
60.4. Kamelet source file Copiar o linkLink copiado para a área de transferência!
https://github.com/openshift-integration/kamelet-catalog/salesforce-create-sink.kamelet.yaml