You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2020/11/27 01:36:42 UTC

[camel-kafka-connector] 21/21: [create-pull-request] automated change

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

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

commit bd783964aa930dcc35151a1014e2c0cc8f18ccc9
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Thu Nov 26 04:06:08 2020 +0000

    [create-pull-request] automated change
---
 .../generated/resources/connectors/camel-salesforce-sink.json    | 9 ++++++++-
 .../generated/resources/connectors/camel-salesforce-source.json  | 9 ++++++++-
 .../src/generated/resources/camel-salesforce-sink.json           | 9 ++++++++-
 .../src/generated/resources/camel-salesforce-source.json         | 9 ++++++++-
 .../src/main/docs/camel-salesforce-kafka-sink-connector.adoc     | 5 +++--
 .../src/main/docs/camel-salesforce-kafka-source-connector.adoc   | 5 +++--
 .../salesforce/CamelSalesforceSinkConnectorConfig.java           | 6 +++++-
 .../salesforce/CamelSalesforceSourceConnectorConfig.java         | 6 +++++-
 .../pages/connectors/camel-salesforce-kafka-sink-connector.adoc  | 5 +++--
 .../connectors/camel-salesforce-kafka-source-connector.adoc      | 5 +++--
 10 files changed, 54 insertions(+), 14 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 c2f48bf..035191b 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
@@ -345,6 +345,13 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.component.salesforce.httpRequestBufferSize": {
+			"name": "camel.component.salesforce.httpRequestBufferSize",
+			"description": "HTTP request buffer size. May need to be increased for large SOQL queries.",
+			"defaultValue": "\"8192\"",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.component.salesforce.includeDetails": {
 			"name": "camel.component.salesforce.includeDetails",
 			"description": "Include details in Salesforce1 Analytics report, defaults to false.",
@@ -433,7 +440,7 @@
 		},
 		"camel.component.salesforce.packages": {
 			"name": "camel.component.salesforce.packages",
-			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
+			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
 			"priority": "MEDIUM",
 			"required": "false"
 		},
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 425fd94..c62ec18 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
@@ -363,6 +363,13 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.component.salesforce.httpRequestBufferSize": {
+			"name": "camel.component.salesforce.httpRequestBufferSize",
+			"description": "HTTP request buffer size. May need to be increased for large SOQL queries.",
+			"defaultValue": "\"8192\"",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.component.salesforce.includeDetails": {
 			"name": "camel.component.salesforce.includeDetails",
 			"description": "Include details in Salesforce1 Analytics report, defaults to false.",
@@ -451,7 +458,7 @@
 		},
 		"camel.component.salesforce.packages": {
 			"name": "camel.component.salesforce.packages",
-			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
+			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
 			"priority": "MEDIUM",
 			"required": "false"
 		},
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 c2f48bf..035191b 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
@@ -345,6 +345,13 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.component.salesforce.httpRequestBufferSize": {
+			"name": "camel.component.salesforce.httpRequestBufferSize",
+			"description": "HTTP request buffer size. May need to be increased for large SOQL queries.",
+			"defaultValue": "\"8192\"",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.component.salesforce.includeDetails": {
 			"name": "camel.component.salesforce.includeDetails",
 			"description": "Include details in Salesforce1 Analytics report, defaults to false.",
@@ -433,7 +440,7 @@
 		},
 		"camel.component.salesforce.packages": {
 			"name": "camel.component.salesforce.packages",
-			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
+			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
 			"priority": "MEDIUM",
 			"required": "false"
 		},
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 425fd94..c62ec18 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
@@ -363,6 +363,13 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.component.salesforce.httpRequestBufferSize": {
+			"name": "camel.component.salesforce.httpRequestBufferSize",
+			"description": "HTTP request buffer size. May need to be increased for large SOQL queries.",
+			"defaultValue": "\"8192\"",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.component.salesforce.includeDetails": {
 			"name": "camel.component.salesforce.includeDetails",
 			"description": "Include details in Salesforce1 Analytics report, defaults to false.",
@@ -451,7 +458,7 @@
 		},
 		"camel.component.salesforce.packages": {
 			"name": "camel.component.salesforce.packages",
-			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
+			"description": "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters\/header values. Multiple packages can be separated by comma.",
 			"priority": "MEDIUM",
 			"required": "false"
 		},
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 a38141e..5f73cc7 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 112 options, which are listed below.
+The camel-salesforce sink connector supports 113 options, which are listed below.
 
 
 
@@ -83,6 +83,7 @@ The camel-salesforce sink connector supports 112 options, which are listed below
 | *camel.component.salesforce.httpClientConnection Timeout* | Connection timeout used by the HttpClient when connecting to the Salesforce server. | 60000L | false | MEDIUM
 | *camel.component.salesforce.httpClientIdleTimeout* | Timeout used by the HttpClient when waiting for response from the Salesforce server. | 10000L | false | MEDIUM
 | *camel.component.salesforce.httpMaxContentLength* | Max content length of an HTTP response. | null | false | MEDIUM
+| *camel.component.salesforce.httpRequestBufferSize* | HTTP request buffer size. May need to be increased for large SOQL queries. | "8192" | false | MEDIUM
 | *camel.component.salesforce.includeDetails* | Include details in Salesforce1 Analytics report, defaults to false. | null | false | MEDIUM
 | *camel.component.salesforce.initialReplayIdMap* | Replay IDs to start from per channel name. | null | false | MEDIUM
 | *camel.component.salesforce.instanceId* | Salesforce1 Analytics report execution instance ID | null | false | MEDIUM
@@ -97,7 +98,7 @@ The camel-salesforce sink connector supports 112 options, which are listed below
 | *camel.component.salesforce.notifyForOperation Undelete* | Notify for un-delete operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.notifyForOperation Update* | Notify for update operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.objectMapper* | Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects. | null | false | MEDIUM
-| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
+| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
 | *camel.component.salesforce.rawPayload* | Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default | false | false | MEDIUM
 | *camel.component.salesforce.reportId* | Salesforce1 Analytics report Id | null | false | MEDIUM
 | *camel.component.salesforce.reportMetadata* | Salesforce1 Analytics report metadata for filtering | 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 48c45c6..f89c55b 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 115 options, which are listed below.
+The camel-salesforce source connector supports 116 options, which are listed below.
 
 
 
@@ -86,6 +86,7 @@ The camel-salesforce source connector supports 115 options, which are listed bel
 | *camel.component.salesforce.httpClientConnection Timeout* | Connection timeout used by the HttpClient when connecting to the Salesforce server. | 60000L | false | MEDIUM
 | *camel.component.salesforce.httpClientIdleTimeout* | Timeout used by the HttpClient when waiting for response from the Salesforce server. | 10000L | false | MEDIUM
 | *camel.component.salesforce.httpMaxContentLength* | Max content length of an HTTP response. | null | false | MEDIUM
+| *camel.component.salesforce.httpRequestBufferSize* | HTTP request buffer size. May need to be increased for large SOQL queries. | "8192" | false | MEDIUM
 | *camel.component.salesforce.includeDetails* | Include details in Salesforce1 Analytics report, defaults to false. | null | false | MEDIUM
 | *camel.component.salesforce.initialReplayIdMap* | Replay IDs to start from per channel name. | null | false | MEDIUM
 | *camel.component.salesforce.instanceId* | Salesforce1 Analytics report execution instance ID | null | false | MEDIUM
@@ -100,7 +101,7 @@ The camel-salesforce source connector supports 115 options, which are listed bel
 | *camel.component.salesforce.notifyForOperation Undelete* | Notify for un-delete operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.notifyForOperation Update* | Notify for update operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.objectMapper* | Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects. | null | false | MEDIUM
-| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
+| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
 | *camel.component.salesforce.rawPayload* | Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default | false | false | MEDIUM
 | *camel.component.salesforce.reportId* | Salesforce1 Analytics report Id | null | false | MEDIUM
 | *camel.component.salesforce.reportMetadata* | Salesforce1 Analytics report metadata for filtering | 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 5dad693..e9e32b6 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
@@ -188,6 +188,9 @@ public class CamelSalesforceSinkConnectorConfig
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_CONF = "camel.component.salesforce.httpMaxContentLength";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DOC = "Max content length of an HTTP response.";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DEFAULT = null;
+    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_CONF = "camel.component.salesforce.httpRequestBufferSize";
+    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DOC = "HTTP request buffer size. May need to be increased for large SOQL queries.";
+    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DEFAULT = "8192";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_INCLUDE_DETAILS_CONF = "camel.component.salesforce.includeDetails";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DOC = "Include details in Salesforce1 Analytics report, defaults to false.";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DEFAULT = null;
@@ -231,7 +234,7 @@ public class CamelSalesforceSinkConnectorConfig
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_OBJECT_MAPPER_DOC = "Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects.";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_OBJECT_MAPPER_DEFAULT = null;
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_PACKAGES_CONF = "camel.component.salesforce.packages";
-    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_PACKAGES_DOC = "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma.";
+    public static final String CAMEL_SINK_SALESFORCE_COMPONENT_PACKAGES_DOC = "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma.";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_PACKAGES_DEFAULT = null;
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PAYLOAD_CONF = "camel.component.salesforce.rawPayload";
     public static final String CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PAYLOAD_DOC = "Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default";
@@ -429,6 +432,7 @@ public class CamelSalesforceSinkConnectorConfig
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_CONNECTION_TIMEOUT_CONF, ConfigDef.Type.LONG, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_CONNECTION_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_CONNECTION_TIMEOUT_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_IDLE_TIMEOUT_CONF, ConfigDef.Type.LONG, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_IDLE_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_IDLE_TIMEOUT_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DOC);
+        conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_INCLUDE_DETAILS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_INITIAL_REPLAY_ID_MAP_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_INITIAL_REPLAY_ID_MAP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_INITIAL_REPLAY_ID_MAP_DOC);
         conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_INSTANCE_ID_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_INSTANCE_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_INSTANCE_ID_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 864c339..61f79ec 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
@@ -197,6 +197,9 @@ public class CamelSalesforceSourceConnectorConfig
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_CONF = "camel.component.salesforce.httpMaxContentLength";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DOC = "Max content length of an HTTP response.";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DEFAULT = null;
+    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_CONF = "camel.component.salesforce.httpRequestBufferSize";
+    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DOC = "HTTP request buffer size. May need to be increased for large SOQL queries.";
+    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DEFAULT = "8192";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_INCLUDE_DETAILS_CONF = "camel.component.salesforce.includeDetails";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DOC = "Include details in Salesforce1 Analytics report, defaults to false.";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DEFAULT = null;
@@ -240,7 +243,7 @@ public class CamelSalesforceSourceConnectorConfig
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_OBJECT_MAPPER_DOC = "Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects.";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_OBJECT_MAPPER_DEFAULT = null;
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_PACKAGES_CONF = "camel.component.salesforce.packages";
-    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_PACKAGES_DOC = "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma.";
+    public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_PACKAGES_DOC = "In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma.";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_PACKAGES_DEFAULT = null;
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_RAW_PAYLOAD_CONF = "camel.component.salesforce.rawPayload";
     public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_RAW_PAYLOAD_DOC = "Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default";
@@ -441,6 +444,7 @@ public class CamelSalesforceSourceConnectorConfig
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_CLIENT_CONNECTION_TIMEOUT_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_CLIENT_CONNECTION_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_CLIENT_CONNECTION_TIMEOUT_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_CLIENT_IDLE_TIMEOUT_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_CLIENT_IDLE_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_CLIENT_IDLE_TIMEOUT_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_MAX_CONTENT_LENGTH_DOC);
+        conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_HTTP_REQUEST_BUFFER_SIZE_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_INCLUDE_DETAILS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_INCLUDE_DETAILS_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_INITIAL_REPLAY_ID_MAP_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_INITIAL_REPLAY_ID_MAP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_INITIAL_REPLAY_ID_MAP_DOC);
         conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_INSTANCE_ID_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_INSTANCE_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_INSTANCE_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 a38141e..5f73cc7 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 112 options, which are listed below.
+The camel-salesforce sink connector supports 113 options, which are listed below.
 
 
 
@@ -83,6 +83,7 @@ The camel-salesforce sink connector supports 112 options, which are listed below
 | *camel.component.salesforce.httpClientConnection Timeout* | Connection timeout used by the HttpClient when connecting to the Salesforce server. | 60000L | false | MEDIUM
 | *camel.component.salesforce.httpClientIdleTimeout* | Timeout used by the HttpClient when waiting for response from the Salesforce server. | 10000L | false | MEDIUM
 | *camel.component.salesforce.httpMaxContentLength* | Max content length of an HTTP response. | null | false | MEDIUM
+| *camel.component.salesforce.httpRequestBufferSize* | HTTP request buffer size. May need to be increased for large SOQL queries. | "8192" | false | MEDIUM
 | *camel.component.salesforce.includeDetails* | Include details in Salesforce1 Analytics report, defaults to false. | null | false | MEDIUM
 | *camel.component.salesforce.initialReplayIdMap* | Replay IDs to start from per channel name. | null | false | MEDIUM
 | *camel.component.salesforce.instanceId* | Salesforce1 Analytics report execution instance ID | null | false | MEDIUM
@@ -97,7 +98,7 @@ The camel-salesforce sink connector supports 112 options, which are listed below
 | *camel.component.salesforce.notifyForOperation Undelete* | Notify for un-delete operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.notifyForOperation Update* | Notify for update operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.objectMapper* | Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects. | null | false | MEDIUM
-| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
+| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
 | *camel.component.salesforce.rawPayload* | Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default | false | false | MEDIUM
 | *camel.component.salesforce.reportId* | Salesforce1 Analytics report Id | null | false | MEDIUM
 | *camel.component.salesforce.reportMetadata* | Salesforce1 Analytics report metadata for filtering | 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 48c45c6..f89c55b 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 115 options, which are listed below.
+The camel-salesforce source connector supports 116 options, which are listed below.
 
 
 
@@ -86,6 +86,7 @@ The camel-salesforce source connector supports 115 options, which are listed bel
 | *camel.component.salesforce.httpClientConnection Timeout* | Connection timeout used by the HttpClient when connecting to the Salesforce server. | 60000L | false | MEDIUM
 | *camel.component.salesforce.httpClientIdleTimeout* | Timeout used by the HttpClient when waiting for response from the Salesforce server. | 10000L | false | MEDIUM
 | *camel.component.salesforce.httpMaxContentLength* | Max content length of an HTTP response. | null | false | MEDIUM
+| *camel.component.salesforce.httpRequestBufferSize* | HTTP request buffer size. May need to be increased for large SOQL queries. | "8192" | false | MEDIUM
 | *camel.component.salesforce.includeDetails* | Include details in Salesforce1 Analytics report, defaults to false. | null | false | MEDIUM
 | *camel.component.salesforce.initialReplayIdMap* | Replay IDs to start from per channel name. | null | false | MEDIUM
 | *camel.component.salesforce.instanceId* | Salesforce1 Analytics report execution instance ID | null | false | MEDIUM
@@ -100,7 +101,7 @@ The camel-salesforce source connector supports 115 options, which are listed bel
 | *camel.component.salesforce.notifyForOperation Undelete* | Notify for un-delete operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.notifyForOperation Update* | Notify for update operation, defaults to false (API version = 29.0) | null | false | MEDIUM
 | *camel.component.salesforce.objectMapper* | Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects. | null | false | MEDIUM
-| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. Set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
+| *camel.component.salesforce.packages* | In what packages are the generated DTO classes. Typically the classes would be generated using camel-salesforce-maven-plugin. This must be set if using the XML format. Also, set it if using the generated DTOs to gain the benefit of using short SObject names in parameters/header values. Multiple packages can be separated by comma. | null | false | MEDIUM
 | *camel.component.salesforce.rawPayload* | Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default | false | false | MEDIUM
 | *camel.component.salesforce.reportId* | Salesforce1 Analytics report Id | null | false | MEDIUM
 | *camel.component.salesforce.reportMetadata* | Salesforce1 Analytics report metadata for filtering | null | false | MEDIUM