This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/camel-master by this push:
     new 107535d  [create-pull-request] automated change
107535d is described below

commit 107535d8582af457ef56f041a1e3181293002880
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Dec 11 03:24:14 2020 +0000

    [create-pull-request] automated change
---
 .../connectors/camel-salesforce-sink.json          | 36 ++++++++++++++--------
 .../connectors/camel-salesforce-source.json        | 12 --------
 .../generated/resources/camel-salesforce-sink.json | 36 ++++++++++++++--------
 .../resources/camel-salesforce-source.json         | 12 --------
 .../camel-salesforce-kafka-sink-connector.adoc     |  8 +++--
 .../camel-salesforce-kafka-source-connector.adoc   |  4 +--
 .../CamelSalesforceSinkConnectorConfig.java        | 24 ++++++++++-----
 .../CamelSalesforceSourceConnectorConfig.java      |  8 -----
 .../camel-salesforce-kafka-sink-connector.adoc     |  8 +++--
 .../camel-salesforce-kafka-source-connector.adoc   |  4 +--
 10 files changed, 76 insertions(+), 76 deletions(-)

diff --git 
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
 
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
index 66fbea2..129be83 100644
--- 
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
+++ 
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
@@ -27,12 +27,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.sink.endpoint.apexUrl": {
-                       "name": "camel.sink.endpoint.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.sink.endpoint.apiVersion": {
                        "name": "camel.sink.endpoint.apiVersion",
                        "description": "Salesforce API version.",
@@ -250,6 +244,18 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
+               "camel.sink.endpoint.apexUrl": {
+                       "name": "camel.sink.endpoint.apexUrl",
+                       "description": "APEX method URL",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
+               "camel.sink.endpoint.compositeMethod": {
+                       "name": "camel.sink.endpoint.compositeMethod",
+                       "description": "Composite (raw) method.",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
                "camel.sink.endpoint.lazyStartProducer": {
                        "name": "camel.sink.endpoint.lazyStartProducer",
                        "description": "Whether the producer should be started 
lazy (on the first message). By starting lazy you can use this to allow 
CamelContext and routes to startup in situations where a producer may otherwise 
fail during starting and cause the route to fail being started. By deferring 
this startup to be lazy then the startup failure can be handled during routing 
messages via Camel's routing error handlers. Beware that when the first message 
is processed then creating and starting the pr [...]
@@ -276,12 +282,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.component.salesforce.apexUrl": {
-                       "name": "camel.component.salesforce.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.component.salesforce.apiVersion": {
                        "name": "camel.component.salesforce.apiVersion",
                        "description": "Salesforce API version.",
@@ -550,6 +550,18 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
+               "camel.component.salesforce.apexUrl": {
+                       "name": "camel.component.salesforce.apexUrl",
+                       "description": "APEX method URL",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
+               "camel.component.salesforce.compositeMethod": {
+                       "name": "camel.component.salesforce.compositeMethod",
+                       "description": "Composite (raw) method.",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
                "camel.component.salesforce.lazyStartProducer": {
                        "name": "camel.component.salesforce.lazyStartProducer",
                        "description": "Whether the producer should be started 
lazy (on the first message). By starting lazy you can use this to allow 
CamelContext and routes to startup in situations where a producer may otherwise 
fail during starting and cause the route to fail being started. By deferring 
this startup to be lazy then the startup failure can be handled during routing 
messages via Camel's routing error handlers. Beware that when the first message 
is processed then creating and starting the pr [...]
diff --git 
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json
 
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json
index 91f1200..9160b32 100644
--- 
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json
+++ 
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json
@@ -27,12 +27,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.source.endpoint.apexUrl": {
-                       "name": "camel.source.endpoint.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.source.endpoint.apiVersion": {
                        "name": "camel.source.endpoint.apiVersion",
                        "description": "Salesforce API version.",
@@ -294,12 +288,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.component.salesforce.apexUrl": {
-                       "name": "camel.component.salesforce.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.component.salesforce.apiVersion": {
                        "name": "camel.component.salesforce.apiVersion",
                        "description": "Salesforce API version.",
diff --git 
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
 
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
index 66fbea2..129be83 100644
--- 
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
+++ 
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
@@ -27,12 +27,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.sink.endpoint.apexUrl": {
-                       "name": "camel.sink.endpoint.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.sink.endpoint.apiVersion": {
                        "name": "camel.sink.endpoint.apiVersion",
                        "description": "Salesforce API version.",
@@ -250,6 +244,18 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
+               "camel.sink.endpoint.apexUrl": {
+                       "name": "camel.sink.endpoint.apexUrl",
+                       "description": "APEX method URL",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
+               "camel.sink.endpoint.compositeMethod": {
+                       "name": "camel.sink.endpoint.compositeMethod",
+                       "description": "Composite (raw) method.",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
                "camel.sink.endpoint.lazyStartProducer": {
                        "name": "camel.sink.endpoint.lazyStartProducer",
                        "description": "Whether the producer should be started 
lazy (on the first message). By starting lazy you can use this to allow 
CamelContext and routes to startup in situations where a producer may otherwise 
fail during starting and cause the route to fail being started. By deferring 
this startup to be lazy then the startup failure can be handled during routing 
messages via Camel's routing error handlers. Beware that when the first message 
is processed then creating and starting the pr [...]
@@ -276,12 +282,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.component.salesforce.apexUrl": {
-                       "name": "camel.component.salesforce.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.component.salesforce.apiVersion": {
                        "name": "camel.component.salesforce.apiVersion",
                        "description": "Salesforce API version.",
@@ -550,6 +550,18 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
+               "camel.component.salesforce.apexUrl": {
+                       "name": "camel.component.salesforce.apexUrl",
+                       "description": "APEX method URL",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
+               "camel.component.salesforce.compositeMethod": {
+                       "name": "camel.component.salesforce.compositeMethod",
+                       "description": "Composite (raw) method.",
+                       "priority": "MEDIUM",
+                       "required": "false"
+               },
                "camel.component.salesforce.lazyStartProducer": {
                        "name": "camel.component.salesforce.lazyStartProducer",
                        "description": "Whether the producer should be started 
lazy (on the first message). By starting lazy you can use this to allow 
CamelContext and routes to startup in situations where a producer may otherwise 
fail during starting and cause the route to fail being started. By deferring 
this startup to be lazy then the startup failure can be handled during routing 
messages via Camel's routing error handlers. Beware that when the first message 
is processed then creating and starting the pr [...]
diff --git 
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
 
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
index 91f1200..9160b32 100644
--- 
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
+++ 
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
@@ -27,12 +27,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.source.endpoint.apexUrl": {
-                       "name": "camel.source.endpoint.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.source.endpoint.apiVersion": {
                        "name": "camel.source.endpoint.apiVersion",
                        "description": "Salesforce API version.",
@@ -294,12 +288,6 @@
                        "priority": "MEDIUM",
                        "required": "false"
                },
-               "camel.component.salesforce.apexUrl": {
-                       "name": "camel.component.salesforce.apexUrl",
-                       "description": "APEX method URL",
-                       "priority": "MEDIUM",
-                       "required": "false"
-               },
                "camel.component.salesforce.apiVersion": {
                        "name": "camel.component.salesforce.apiVersion",
                        "description": "Salesforce API version.",
diff --git 
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
 
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
index 5750222..465bb97 100644
--- 
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
+++ 
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@ 
connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkCo
 ----
 
 
-The camel-salesforce sink connector supports 113 options, which are listed 
below.
+The camel-salesforce sink connector supports 115 options, which are listed 
below.
 
 
 
@@ -32,7 +32,6 @@ The camel-salesforce sink connector supports 113 options, 
which are listed below
 | *camel.sink.path.operationName* | The operation to use One of: [getVersions] 
[getResources] [getGlobalObjects] [getBasicInfo] [getDescription] [getSObject] 
[createSObject] [updateSObject] [deleteSObject] [getSObjectWithId] 
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore] 
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob] 
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults] 
[createBatchQuery] [getQueryResultIds] [getQ [...]
 | *camel.sink.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
 | *camel.sink.endpoint.apexQueryParams* | Query params for APEX method | null 
| false | MEDIUM
-| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
 | *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false 
| MEDIUM
 | *camel.sink.endpoint.backoffIncrement* | Backoff interval increment for 
Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.sink.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
@@ -68,11 +67,12 @@ The camel-salesforce sink connector supports 113 options, 
which are listed below
 | *camel.sink.endpoint.sObjectQuery* | Salesforce SOQL query string | null | 
false | MEDIUM
 | *camel.sink.endpoint.sObjectSearch* | Salesforce SOSL search string | null | 
false | MEDIUM
 | *camel.sink.endpoint.updateTopic* | Whether to update an existing Push Topic 
when using the Streaming API, defaults to false | false | false | MEDIUM
+| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
+| *camel.sink.endpoint.compositeMethod* | Composite (raw) method. | null | 
false | MEDIUM
 | *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be 
started lazy (on the first message). By starting lazy you can use this to allow 
CamelContext and routes to startup in situations where a producer may otherwise 
fail during starting and cause the route to fail being started. By deferring 
this startup to be lazy then the startup failure can be handled during routing 
messages via Camel's routing error handlers. Beware that when the first message 
is processed then cre [...]
 | *camel.sink.endpoint.synchronous* | Sets whether synchronous processing 
should be strictly used, or Camel is allowed to use asynchronous processing (if 
supported). | false | false | MEDIUM
 | *camel.component.salesforce.apexMethod* | APEX method name | null | false | 
MEDIUM
 | *camel.component.salesforce.apexQueryParams* | Query params for APEX method 
| null | false | MEDIUM
-| *camel.component.salesforce.apexUrl* | APEX method URL | null | false | 
MEDIUM
 | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | 
false | MEDIUM
 | *camel.component.salesforce.backoffIncrement* | Backoff interval increment 
for Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | 
MEDIUM
@@ -116,6 +116,8 @@ The camel-salesforce sink connector supports 113 options, 
which are listed below
 | *camel.component.salesforce.config* | Global endpoint configuration - use to 
set values that are common to all endpoints | null | false | MEDIUM
 | *camel.component.salesforce.httpClientProperties* | Used to set any 
properties that can be configured on the underlying HTTP client. Have a look at 
properties of SalesforceHttpClient and the Jetty HttpClient for all available 
options. | null | false | MEDIUM
 | *camel.component.salesforce.longPollingTransport Properties* | Used to set 
any properties that can be configured on the LongPollingTransport used by the 
BayeuxClient (CometD) used by the streaming api | null | false | MEDIUM
+| *camel.component.salesforce.apexUrl* | APEX method URL | null | false | 
MEDIUM
+| *camel.component.salesforce.compositeMethod* | Composite (raw) method. | 
null | false | MEDIUM
 | *camel.component.salesforce.lazyStartProducer* | Whether the producer should 
be started lazy (on the first message). By starting lazy you can use this to 
allow CamelContext and routes to startup in situations where a producer may 
otherwise fail during starting and cause the route to fail being started. By 
deferring this startup to be lazy then the startup failure can be handled 
during routing messages via Camel's routing error handlers. Beware that when 
the first message is processed t [...]
 | *camel.component.salesforce.autowiredEnabled* | Whether autowiring is 
enabled. This is used for automatic autowiring options (the option must be 
marked as autowired) by looking up in the registry to find if there is a single 
instance of matching type, which then gets configured on the component. This 
can be used for automatic configuring JDBC data sources, JMS connection 
factories, AWS Clients, etc. | true | false | MEDIUM
 | *camel.component.salesforce.httpProxyExcluded Addresses* | A list of 
addresses for which HTTP proxy server should not be used. | null | false | 
MEDIUM
diff --git 
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
 
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
index 4fca6bc..f57838f 100644
--- 
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
+++ 
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
@@ -22,7 +22,7 @@ 
connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSource
 ----
 
 
-The camel-salesforce source connector supports 116 options, which are listed 
below.
+The camel-salesforce source connector supports 114 options, which are listed 
below.
 
 
 
@@ -32,7 +32,6 @@ The camel-salesforce source connector supports 116 options, 
which are listed bel
 | *camel.source.path.topicName* | The name of the topic/channel to use | null 
| false | MEDIUM
 | *camel.source.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
 | *camel.source.endpoint.apexQueryParams* | Query params for APEX method | 
null | false | MEDIUM
-| *camel.source.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
 | *camel.source.endpoint.apiVersion* | Salesforce API version. | "50.0" | 
false | MEDIUM
 | *camel.source.endpoint.backoffIncrement* | Backoff interval increment for 
Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.source.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
@@ -75,7 +74,6 @@ The camel-salesforce source connector supports 116 options, 
which are listed bel
 | *camel.source.endpoint.synchronous* | Sets whether synchronous processing 
should be strictly used, or Camel is allowed to use asynchronous processing (if 
supported). | false | false | MEDIUM
 | *camel.component.salesforce.apexMethod* | APEX method name | null | false | 
MEDIUM
 | *camel.component.salesforce.apexQueryParams* | Query params for APEX method 
| null | false | MEDIUM
-| *camel.component.salesforce.apexUrl* | APEX method URL | null | false | 
MEDIUM
 | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | 
false | MEDIUM
 | *camel.component.salesforce.backoffIncrement* | Backoff interval increment 
for Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | 
MEDIUM
diff --git 
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
 
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
index 66e02ae..8b3b6f3 100644
--- 
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
+++ 
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
@@ -35,9 +35,6 @@ public class CamelSalesforceSinkConnectorConfig
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF = 
"camel.sink.endpoint.apexQueryParams";
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC = "Query params for APEX 
method";
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT = null;
-    public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF = 
"camel.sink.endpoint.apexUrl";
-    public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC = 
"APEX method URL";
-    public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT 
= null;
     public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_CONF 
= "camel.sink.endpoint.apiVersion";
     public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DOC 
= "Salesforce API version.";
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "50.0";
@@ -143,6 +140,12 @@ public class CamelSalesforceSinkConnectorConfig
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_CONF = 
"camel.sink.endpoint.updateTopic";
     public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DOC 
= "Whether to update an existing Push Topic when using the Streaming API, 
defaults to false";
     public static final Boolean 
CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DEFAULT = false;
+    public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF = 
"camel.sink.endpoint.apexUrl";
+    public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC = 
"APEX method URL";
+    public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT 
= null;
+    public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_CONF = 
"camel.sink.endpoint.compositeMethod";
+    public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DOC = "Composite (raw) method.";
+    public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DEFAULT = null;
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_CONF = 
"camel.sink.endpoint.lazyStartProducer";
     public static final String 
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DOC = "Whether the producer 
should be started lazy (on the first message). By starting lazy you can use 
this to allow CamelContext and routes to startup in situations where a producer 
may otherwise fail during starting and cause the route to fail being started. 
By deferring this startup to be lazy then the startup failure can be handled 
during routing messages via Camel's routing error handlers. Beware that [...]
     public static final Boolean 
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -155,9 +158,6 @@ public class CamelSalesforceSinkConnectorConfig
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF = 
"camel.component.salesforce.apexQueryParams";
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC = "Query params for APEX 
method";
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT = null;
-    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF = 
"camel.component.salesforce.apexUrl";
-    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC = 
"APEX method URL";
-    public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null;
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_CONF = 
"camel.component.salesforce.apiVersion";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DOC 
= "Salesforce API version.";
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "50.0";
@@ -287,6 +287,12 @@ public class CamelSalesforceSinkConnectorConfig
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_CONF = 
"camel.component.salesforce.longPollingTransportProperties";
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DOC = "Used 
to set any properties that can be configured on the LongPollingTransport used 
by the BayeuxClient (CometD) used by the streaming api";
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DEFAULT = 
null;
+    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF = 
"camel.component.salesforce.apexUrl";
+    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC = 
"APEX method URL";
+    public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null;
+    public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_CONF = 
"camel.component.salesforce.compositeMethod";
+    public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DOC = "Composite (raw) 
method.";
+    public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DEFAULT = null;
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_CONF = 
"camel.component.salesforce.lazyStartProducer";
     public static final String 
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DOC = "Whether the producer 
should be started lazy (on the first message). By starting lazy you can use 
this to allow CamelContext and routes to startup in situations where a producer 
may otherwise fail during starting and cause the route to fail being started. 
By deferring this startup to be lazy then the startup failure can be handled 
during routing messages via Camel's routing error handlers. Beware tha [...]
     public static final Boolean 
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -381,7 +387,6 @@ public class CamelSalesforceSinkConnectorConfig
         conf.define(CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC);
-        conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_CONF, 
ConfigDef.Type.LONG, CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_BATCH_ID_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_BATCH_ID_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_BATCH_ID_DOC);
@@ -417,11 +422,12 @@ public class CamelSalesforceSinkConnectorConfig
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_QUERY_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_QUERY_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_QUERY_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_SEARCH_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_SEARCH_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_SEARCH_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_CONF, 
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DOC);
+        conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC);
+        conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_CONF, 
ConfigDef.Type.BOOLEAN, 
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_SYNCHRONOUS_CONF, 
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SALESFORCE_ENDPOINT_SYNCHRONOUS_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_SYNCHRONOUS_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC);
-        conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_CONF, 
ConfigDef.Type.LONG, CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_BATCH_ID_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_BATCH_ID_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_BATCH_ID_DOC);
@@ -465,6 +471,8 @@ public class CamelSalesforceSinkConnectorConfig
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_CONFIG_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_CONFIG_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_CONFIG_DOC);
         
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_PROPERTIES_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_PROPERTIES_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_PROPERTIES_DOC);
         
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_CONF,
 ConfigDef.Type.STRING, 
CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DOC);
+        conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF, 
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC);
+        conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_CONF, 
ConfigDef.Type.BOOLEAN, 
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_CONF, 
ConfigDef.Type.BOOLEAN, 
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_DOC);
         
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_EXCLUDED_ADDRESSES_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_EXCLUDED_ADDRESSES_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_EXCLUDED_ADDRESSES_DOC);
diff --git 
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
 
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
index 56f8df9..81c71ef 100644
--- 
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
+++ 
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
@@ -35,9 +35,6 @@ public class CamelSalesforceSourceConnectorConfig
     public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF = 
"camel.source.endpoint.apexQueryParams";
     public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC = "Query params for APEX 
method";
     public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT = null;
-    public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_CONF 
= "camel.source.endpoint.apexUrl";
-    public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DOC = 
"APEX method URL";
-    public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT = null;
     public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_CONF = 
"camel.source.endpoint.apiVersion";
     public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DOC = "Salesforce API version.";
     public static final String 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "50.0";
@@ -164,9 +161,6 @@ public class CamelSalesforceSourceConnectorConfig
     public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF = 
"camel.component.salesforce.apexQueryParams";
     public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC = "Query params for 
APEX method";
     public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT = null;
-    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_CONF 
= "camel.component.salesforce.apexUrl";
-    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DOC 
= "APEX method URL";
-    public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null;
     public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_CONF = 
"camel.component.salesforce.apiVersion";
     public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DOC = "Salesforce API version.";
     public static final String 
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "50.0";
@@ -390,7 +384,6 @@ public class CamelSalesforceSourceConnectorConfig
         conf.define(CAMEL_SOURCE_SALESFORCE_PATH_TOPIC_NAME_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_PATH_TOPIC_NAME_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_PATH_TOPIC_NAME_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_METHOD_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_METHOD_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_METHOD_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC);
-        conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_CONF, 
ConfigDef.Type.LONG, 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_BATCH_ID_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_BATCH_ID_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_BATCH_ID_DOC);
@@ -433,7 +426,6 @@ public class CamelSalesforceSourceConnectorConfig
         conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_SYNCHRONOUS_CONF, 
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SALESFORCE_ENDPOINT_SYNCHRONOUS_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_SYNCHRONOUS_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_METHOD_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_METHOD_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_METHOD_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF, 
ConfigDef.Type.STRING, 
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC);
-        conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_CONF, 
ConfigDef.Type.LONG, 
CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DEFAULT, 
ConfigDef.Importance.MEDIUM, 
CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_BATCH_ID_CONF, 
ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_BATCH_ID_DEFAULT, 
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_BATCH_ID_DOC);
diff --git 
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc 
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
index 5750222..465bb97 100644
--- 
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
+++ 
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@ 
connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkCo
 ----
 
 
-The camel-salesforce sink connector supports 113 options, which are listed 
below.
+The camel-salesforce sink connector supports 115 options, which are listed 
below.
 
 
 
@@ -32,7 +32,6 @@ The camel-salesforce sink connector supports 113 options, 
which are listed below
 | *camel.sink.path.operationName* | The operation to use One of: [getVersions] 
[getResources] [getGlobalObjects] [getBasicInfo] [getDescription] [getSObject] 
[createSObject] [updateSObject] [deleteSObject] [getSObjectWithId] 
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore] 
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob] 
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults] 
[createBatchQuery] [getQueryResultIds] [getQ [...]
 | *camel.sink.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
 | *camel.sink.endpoint.apexQueryParams* | Query params for APEX method | null 
| false | MEDIUM
-| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
 | *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false 
| MEDIUM
 | *camel.sink.endpoint.backoffIncrement* | Backoff interval increment for 
Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.sink.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
@@ -68,11 +67,12 @@ The camel-salesforce sink connector supports 113 options, 
which are listed below
 | *camel.sink.endpoint.sObjectQuery* | Salesforce SOQL query string | null | 
false | MEDIUM
 | *camel.sink.endpoint.sObjectSearch* | Salesforce SOSL search string | null | 
false | MEDIUM
 | *camel.sink.endpoint.updateTopic* | Whether to update an existing Push Topic 
when using the Streaming API, defaults to false | false | false | MEDIUM
+| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
+| *camel.sink.endpoint.compositeMethod* | Composite (raw) method. | null | 
false | MEDIUM
 | *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be 
started lazy (on the first message). By starting lazy you can use this to allow 
CamelContext and routes to startup in situations where a producer may otherwise 
fail during starting and cause the route to fail being started. By deferring 
this startup to be lazy then the startup failure can be handled during routing 
messages via Camel's routing error handlers. Beware that when the first message 
is processed then cre [...]
 | *camel.sink.endpoint.synchronous* | Sets whether synchronous processing 
should be strictly used, or Camel is allowed to use asynchronous processing (if 
supported). | false | false | MEDIUM
 | *camel.component.salesforce.apexMethod* | APEX method name | null | false | 
MEDIUM
 | *camel.component.salesforce.apexQueryParams* | Query params for APEX method 
| null | false | MEDIUM
-| *camel.component.salesforce.apexUrl* | APEX method URL | null | false | 
MEDIUM
 | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | 
false | MEDIUM
 | *camel.component.salesforce.backoffIncrement* | Backoff interval increment 
for Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | 
MEDIUM
@@ -116,6 +116,8 @@ The camel-salesforce sink connector supports 113 options, 
which are listed below
 | *camel.component.salesforce.config* | Global endpoint configuration - use to 
set values that are common to all endpoints | null | false | MEDIUM
 | *camel.component.salesforce.httpClientProperties* | Used to set any 
properties that can be configured on the underlying HTTP client. Have a look at 
properties of SalesforceHttpClient and the Jetty HttpClient for all available 
options. | null | false | MEDIUM
 | *camel.component.salesforce.longPollingTransport Properties* | Used to set 
any properties that can be configured on the LongPollingTransport used by the 
BayeuxClient (CometD) used by the streaming api | null | false | MEDIUM
+| *camel.component.salesforce.apexUrl* | APEX method URL | null | false | 
MEDIUM
+| *camel.component.salesforce.compositeMethod* | Composite (raw) method. | 
null | false | MEDIUM
 | *camel.component.salesforce.lazyStartProducer* | Whether the producer should 
be started lazy (on the first message). By starting lazy you can use this to 
allow CamelContext and routes to startup in situations where a producer may 
otherwise fail during starting and cause the route to fail being started. By 
deferring this startup to be lazy then the startup failure can be handled 
during routing messages via Camel's routing error handlers. Beware that when 
the first message is processed t [...]
 | *camel.component.salesforce.autowiredEnabled* | Whether autowiring is 
enabled. This is used for automatic autowiring options (the option must be 
marked as autowired) by looking up in the registry to find if there is a single 
instance of matching type, which then gets configured on the component. This 
can be used for automatic configuring JDBC data sources, JMS connection 
factories, AWS Clients, etc. | true | false | MEDIUM
 | *camel.component.salesforce.httpProxyExcluded Addresses* | A list of 
addresses for which HTTP proxy server should not be used. | null | false | 
MEDIUM
diff --git 
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
 
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
index 4fca6bc..f57838f 100644
--- 
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
+++ 
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
@@ -22,7 +22,7 @@ 
connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSource
 ----
 
 
-The camel-salesforce source connector supports 116 options, which are listed 
below.
+The camel-salesforce source connector supports 114 options, which are listed 
below.
 
 
 
@@ -32,7 +32,6 @@ The camel-salesforce source connector supports 116 options, 
which are listed bel
 | *camel.source.path.topicName* | The name of the topic/channel to use | null 
| false | MEDIUM
 | *camel.source.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
 | *camel.source.endpoint.apexQueryParams* | Query params for APEX method | 
null | false | MEDIUM
-| *camel.source.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
 | *camel.source.endpoint.apiVersion* | Salesforce API version. | "50.0" | 
false | MEDIUM
 | *camel.source.endpoint.backoffIncrement* | Backoff interval increment for 
Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.source.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
@@ -75,7 +74,6 @@ The camel-salesforce source connector supports 116 options, 
which are listed bel
 | *camel.source.endpoint.synchronous* | Sets whether synchronous processing 
should be strictly used, or Camel is allowed to use asynchronous processing (if 
supported). | false | false | MEDIUM
 | *camel.component.salesforce.apexMethod* | APEX method name | null | false | 
MEDIUM
 | *camel.component.salesforce.apexQueryParams* | Query params for APEX method 
| null | false | MEDIUM
-| *camel.component.salesforce.apexUrl* | APEX method URL | null | false | 
MEDIUM
 | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | 
false | MEDIUM
 | *camel.component.salesforce.backoffIncrement* | Backoff interval increment 
for Streaming connection restart attempts for failures beyond CometD 
auto-reconnect. | 1000L | false | MEDIUM
 | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | 
MEDIUM

Reply via email to