This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push: new abb297f [create-pull-request] automated change abb297f is described below commit abb297fa8ac5d031afbab25764d84765a8e9318f Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Fri Jun 11 03:42:44 2021 +0000 [create-pull-request] automated change --- .../connectors}/camel-hwcloud-functiongraph-sink.json | 3 ++- .../src/generated/resources/connectors/camel-solr-sink.json | 6 +++--- .../generated/resources/connectors/camel-solrCloud-sink.json | 6 +++--- .../src/generated/resources/connectors/camel-solrs-sink.json | 6 +++--- .../generated/resources/camel-hwcloud-functiongraph-sink.json | 3 ++- .../docs/camel-hwcloud-functiongraph-kafka-sink-connector.adoc | 6 +----- .../CamelHwcloudfunctiongraphSinkConnectorConfig.java | 2 +- .../src/generated/resources/camel-solr-sink.json | 6 +++--- .../src/main/docs/camel-solr-kafka-sink-connector.adoc | 6 +++--- .../kafkaconnector/solr/CamelSolrSinkConnectorConfig.java | 6 +++--- .../src/generated/resources/camel-solrCloud-sink.json | 6 +++--- .../src/main/docs/camel-solrCloud-kafka-sink-connector.adoc | 6 +++--- .../solrcloud/CamelSolrcloudSinkConnectorConfig.java | 6 +++--- .../src/generated/resources/camel-solrs-sink.json | 6 +++--- .../src/main/docs/camel-solrs-kafka-sink-connector.adoc | 6 +++--- .../kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java | 6 +++--- .../camel-hwcloud-functiongraph-kafka-sink-connector.adoc | 6 +----- .../ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc | 10 +++------- .../pages/connectors/camel-solrCloud-kafka-sink-connector.adoc | 10 +++------- .../pages/connectors/camel-solrs-kafka-sink-connector.adoc | 10 +++------- 20 files changed, 52 insertions(+), 70 deletions(-) diff --git a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-functiongraph-sink.json similarity index 99% copy from connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json copy to camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-functiongraph-sink.json index 7d87f88..897543a 100644 --- a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-functiongraph-sink.json @@ -30,6 +30,7 @@ "camel.sink.endpoint.functionPackage": { "name": "camel.sink.endpoint.functionPackage", "description": "Functions that can be logically grouped together", + "defaultValue": "\"default\"", "priority": "MEDIUM", "required": "false" }, @@ -116,4 +117,4 @@ "required": "false" } } -} +} \ No newline at end of file diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json index 52d80e1..eadccf7 100644 --- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solr-sink.json @@ -36,7 +36,7 @@ }, "camel.sink.endpoint.httpClient": { "name": "camel.sink.endpoint.httpClient", - "description": "Sets the http client to be used by the solrClient", + "description": "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set.", "priority": "MEDIUM", "required": "false" }, @@ -67,7 +67,7 @@ }, "camel.sink.endpoint.solrClient": { "name": "camel.sink.endpoint.solrClient", - "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or [...] + "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the solr operation is INS [...] "priority": "MEDIUM", "required": "false" }, @@ -105,7 +105,7 @@ }, "camel.sink.endpoint.zkHost": { "name": "camel.sink.endpoint.zkHost", - "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124\/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123\/solr' or 'localhost:8123\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] + "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182\/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181\/solr' or 'localhost:2181\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot parameter).", "priority": "MEDIUM", "required": "false" }, diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json index 9760bcf..290dcd4 100644 --- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrCloud-sink.json @@ -36,7 +36,7 @@ }, "camel.sink.endpoint.httpClient": { "name": "camel.sink.endpoint.httpClient", - "description": "Sets the http client to be used by the solrClient", + "description": "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set.", "priority": "MEDIUM", "required": "false" }, @@ -67,7 +67,7 @@ }, "camel.sink.endpoint.solrClient": { "name": "camel.sink.endpoint.solrClient", - "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or [...] + "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the solr operation is INS [...] "priority": "MEDIUM", "required": "false" }, @@ -105,7 +105,7 @@ }, "camel.sink.endpoint.zkHost": { "name": "camel.sink.endpoint.zkHost", - "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124\/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123\/solr' or 'localhost:8123\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] + "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182\/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181\/solr' or 'localhost:2181\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot parameter).", "priority": "MEDIUM", "required": "false" }, diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json index 73d6d79..62c499a 100644 --- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-solrs-sink.json @@ -36,7 +36,7 @@ }, "camel.sink.endpoint.httpClient": { "name": "camel.sink.endpoint.httpClient", - "description": "Sets the http client to be used by the solrClient", + "description": "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set.", "priority": "MEDIUM", "required": "false" }, @@ -67,7 +67,7 @@ }, "camel.sink.endpoint.solrClient": { "name": "camel.sink.endpoint.solrClient", - "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or [...] + "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the solr operation is INS [...] "priority": "MEDIUM", "required": "false" }, @@ -105,7 +105,7 @@ }, "camel.sink.endpoint.zkHost": { "name": "camel.sink.endpoint.zkHost", - "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124\/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123\/solr' or 'localhost:8123\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] + "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182\/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181\/solr' or 'localhost:2181\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot parameter).", "priority": "MEDIUM", "required": "false" }, diff --git a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json b/connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json index 7d87f88..897543a 100644 --- a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json +++ b/connectors/camel-hwcloud-functiongraph-kafka-connector/src/generated/resources/camel-hwcloud-functiongraph-sink.json @@ -30,6 +30,7 @@ "camel.sink.endpoint.functionPackage": { "name": "camel.sink.endpoint.functionPackage", "description": "Functions that can be logically grouped together", + "defaultValue": "\"default\"", "priority": "MEDIUM", "required": "false" }, @@ -116,4 +117,4 @@ "required": "false" } } -} +} \ No newline at end of file diff --git a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/docs/camel-hwcloud-functiongraph-kafka-sink-connector.adoc b/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/docs/camel-hwcloud-functiongraph-kafka-sink-connector.adoc index 8d1b886..26cef89 100644 --- a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/docs/camel-hwcloud-functiongraph-kafka-sink-connector.adoc +++ b/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/docs/camel-hwcloud-functiongraph-kafka-sink-connector.adoc @@ -34,7 +34,7 @@ The camel-hwcloud-functiongraph sink connector supports 17 options, which are li | *camel.sink.path.operation* | Operation to be performed | null | true | HIGH | *camel.sink.endpoint.endpoint* | FunctionGraph url. Carries higher precedence than region parameter based client initialization | null | false | MEDIUM | *camel.sink.endpoint.functionName* | Name of the function to invoke | null | false | MEDIUM -| *camel.sink.endpoint.functionPackage* | Functions that can be logically grouped together | null | false | MEDIUM +| *camel.sink.endpoint.functionPackage* | Functions that can be logically grouped together | "default" | 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.projectId* | Cloud project ID | null | true | HIGH | *camel.sink.endpoint.region* | FunctionGraph service region. This is lower precedence than endpoint based configuration | null | true | HIGH @@ -65,8 +65,4 @@ The camel-hwcloud-functiongraph sink connector has no transforms out of the box. The camel-hwcloud-functiongraph sink connector has no aggregation strategies out of the box. - - - - // kafka-connector options: END diff --git a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudfunctiongraph/CamelHwcloudfunctiongraphSinkConnectorConfig.java b/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudfunctiongraph/CamelHwcloudfunctiongraphSinkConnectorConfig.java index c3c02bb..8a50806 100644 --- a/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudfunctiongraph/CamelHwcloudfunctiongraphSinkConnectorConfig.java +++ b/connectors/camel-hwcloud-functiongraph-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudfunctiongraph/CamelHwcloudfunctiongraphSinkConnectorConfig.java @@ -37,7 +37,7 @@ public class CamelHwcloudfunctiongraphSinkConnectorConfig public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_FUNCTION_NAME_DEFAULT = null; public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_FUNCTION_PACKAGE_CONF = "camel.sink.endpoint.functionPackage"; public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_FUNCTION_PACKAGE_DOC = "Functions that can be logically grouped together"; - public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_FUNCTION_PACKAGE_DEFAULT = null; + public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_FUNCTION_PACKAGE_DEFAULT = "default"; public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer"; public static final String CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_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. B [...] public static final Boolean CAMEL_SINK_HWCLOUDFUNCTIONGRAPH_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false; diff --git a/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json b/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json index 52d80e1..eadccf7 100644 --- a/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json +++ b/connectors/camel-solr-kafka-connector/src/generated/resources/camel-solr-sink.json @@ -36,7 +36,7 @@ }, "camel.sink.endpoint.httpClient": { "name": "camel.sink.endpoint.httpClient", - "description": "Sets the http client to be used by the solrClient", + "description": "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set.", "priority": "MEDIUM", "required": "false" }, @@ -67,7 +67,7 @@ }, "camel.sink.endpoint.solrClient": { "name": "camel.sink.endpoint.solrClient", - "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or [...] + "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the solr operation is INS [...] "priority": "MEDIUM", "required": "false" }, @@ -105,7 +105,7 @@ }, "camel.sink.endpoint.zkHost": { "name": "camel.sink.endpoint.zkHost", - "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124\/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123\/solr' or 'localhost:8123\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] + "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182\/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181\/solr' or 'localhost:2181\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot parameter).", "priority": "MEDIUM", "required": "false" }, diff --git a/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc b/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc index b581946..5206298 100644 --- a/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc +++ b/connectors/camel-solr-kafka-connector/src/main/docs/camel-solr-kafka-sink-connector.adoc @@ -35,18 +35,18 @@ The camel-solr sink connector supports 22 options, which are listed below. | *camel.sink.endpoint.autoCommit* | If true, each producer operation will be automatically followed by a commit | false | false | MEDIUM | *camel.sink.endpoint.connectionTimeout* | Sets the connection timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost on the underlying HttpConnectionManager | null | false | LOW -| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient | null | false | MEDIUM +| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set. | 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.maxRetries* | Maximum number of retries to attempt in the event of transient errors | null | false | LOW | *camel.sink.endpoint.maxTotalConnections* | maxTotalConnection on the underlying HttpConnectionManager | null | false | LOW | *camel.sink.endpoint.requestHandler* | Set the request handler to be used | null | false | MEDIUM -| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme [...] +| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the sol [...] | *camel.sink.endpoint.soTimeout* | Sets the socket timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.streamingQueueSize* | Sets the queue size for the ConcurrentUpdateSolrClient | 10 | false | MEDIUM | *camel.sink.endpoint.streamingThreadCount* | Sets the number of threads for the ConcurrentUpdateSolrClient | 2 | false | MEDIUM | *camel.sink.endpoint.collection* | Set the default collection for SolrCloud | null | false | MEDIUM | *camel.sink.endpoint.zkChroot* | Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot') | null | false | MEDIUM -| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zk [...] +| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] | *camel.sink.endpoint.allowCompression* | Server side must support gzip or deflate for this to have any effect | null | false | MEDIUM | *camel.sink.endpoint.followRedirects* | Indicates whether redirects are used to get to the Solr server | null | false | MEDIUM | *camel.sink.endpoint.password* | Sets password for basic auth plugin enabled servers | null | false | MEDIUM diff --git a/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java b/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java index 1064097..cd797ac 100644 --- a/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java +++ b/connectors/camel-solr-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java @@ -37,7 +37,7 @@ public class CamelSolrSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_SOLR_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DOC = "maxConnectionsPerHost on the underlying HttpConnectionManager"; public static final String CAMEL_SINK_SOLR_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DEFAULT = null; public static final String CAMEL_SINK_SOLR_ENDPOINT_HTTP_CLIENT_CONF = "camel.sink.endpoint.httpClient"; - public static final String CAMEL_SINK_SOLR_ENDPOINT_HTTP_CLIENT_DOC = "Sets the http client to be used by the solrClient"; + public static final String CAMEL_SINK_SOLR_ENDPOINT_HTTP_CLIENT_DOC = "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set."; public static final String CAMEL_SINK_SOLR_ENDPOINT_HTTP_CLIENT_DEFAULT = null; public static final String CAMEL_SINK_SOLR_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer"; public static final String CAMEL_SINK_SOLR_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 when [...] @@ -52,7 +52,7 @@ public class CamelSolrSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_SOLR_ENDPOINT_REQUEST_HANDLER_DOC = "Set the request handler to be used"; public static final String CAMEL_SINK_SOLR_ENDPOINT_REQUEST_HANDLER_DEFAULT = null; public static final String CAMEL_SINK_SOLR_ENDPOINT_SOLR_CLIENT_CONF = "camel.sink.endpoint.solrClient"; - public static final String CAMEL_SINK_SOLR_ENDPOINT_SOLR_CLIENT_DOC = "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), [...] + public static final String CAMEL_SINK_SOLR_ENDPOINT_SOLR_CLIENT_DOC = "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not [...] public static final String CAMEL_SINK_SOLR_ENDPOINT_SOLR_CLIENT_DEFAULT = null; public static final String CAMEL_SINK_SOLR_ENDPOINT_SO_TIMEOUT_CONF = "camel.sink.endpoint.soTimeout"; public static final String CAMEL_SINK_SOLR_ENDPOINT_SO_TIMEOUT_DOC = "Sets the socket timeout on the SolrClient"; @@ -70,7 +70,7 @@ public class CamelSolrSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_SOLR_ENDPOINT_ZK_CHROOT_DOC = "Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot')"; public static final String CAMEL_SINK_SOLR_ENDPOINT_ZK_CHROOT_DEFAULT = null; public static final String CAMEL_SINK_SOLR_ENDPOINT_ZK_HOST_CONF = "camel.sink.endpoint.zkHost"; - public static final String CAMEL_SINK_SOLR_ENDPOINT_ZK_HOST_DOC = "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (t [...] + public static final String CAMEL_SINK_SOLR_ENDPOINT_ZK_HOST_DOC = "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behavi [...] public static final String CAMEL_SINK_SOLR_ENDPOINT_ZK_HOST_DEFAULT = null; public static final String CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_CONF = "camel.sink.endpoint.allowCompression"; public static final String CAMEL_SINK_SOLR_ENDPOINT_ALLOW_COMPRESSION_DOC = "Server side must support gzip or deflate for this to have any effect"; diff --git a/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json b/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json index 9760bcf..290dcd4 100644 --- a/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json +++ b/connectors/camel-solrcloud-kafka-connector/src/generated/resources/camel-solrCloud-sink.json @@ -36,7 +36,7 @@ }, "camel.sink.endpoint.httpClient": { "name": "camel.sink.endpoint.httpClient", - "description": "Sets the http client to be used by the solrClient", + "description": "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set.", "priority": "MEDIUM", "required": "false" }, @@ -67,7 +67,7 @@ }, "camel.sink.endpoint.solrClient": { "name": "camel.sink.endpoint.solrClient", - "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or [...] + "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the solr operation is INS [...] "priority": "MEDIUM", "required": "false" }, @@ -105,7 +105,7 @@ }, "camel.sink.endpoint.zkHost": { "name": "camel.sink.endpoint.zkHost", - "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124\/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123\/solr' or 'localhost:8123\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] + "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182\/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181\/solr' or 'localhost:2181\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot parameter).", "priority": "MEDIUM", "required": "false" }, diff --git a/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc b/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc index d28b7a6..9fed037 100644 --- a/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc +++ b/connectors/camel-solrcloud-kafka-connector/src/main/docs/camel-solrCloud-kafka-sink-connector.adoc @@ -35,18 +35,18 @@ The camel-solrCloud sink connector supports 22 options, which are listed below. | *camel.sink.endpoint.autoCommit* | If true, each producer operation will be automatically followed by a commit | false | false | MEDIUM | *camel.sink.endpoint.connectionTimeout* | Sets the connection timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost on the underlying HttpConnectionManager | null | false | LOW -| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient | null | false | MEDIUM +| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set. | 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.maxRetries* | Maximum number of retries to attempt in the event of transient errors | null | false | LOW | *camel.sink.endpoint.maxTotalConnections* | maxTotalConnection on the underlying HttpConnectionManager | null | false | LOW | *camel.sink.endpoint.requestHandler* | Set the request handler to be used | null | false | MEDIUM -| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme [...] +| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the sol [...] | *camel.sink.endpoint.soTimeout* | Sets the socket timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.streamingQueueSize* | Sets the queue size for the ConcurrentUpdateSolrClient | 10 | false | MEDIUM | *camel.sink.endpoint.streamingThreadCount* | Sets the number of threads for the ConcurrentUpdateSolrClient | 2 | false | MEDIUM | *camel.sink.endpoint.collection* | Set the default collection for SolrCloud | null | false | MEDIUM | *camel.sink.endpoint.zkChroot* | Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot') | null | false | MEDIUM -| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zk [...] +| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] | *camel.sink.endpoint.allowCompression* | Server side must support gzip or deflate for this to have any effect | null | false | MEDIUM | *camel.sink.endpoint.followRedirects* | Indicates whether redirects are used to get to the Solr server | null | false | MEDIUM | *camel.sink.endpoint.password* | Sets password for basic auth plugin enabled servers | null | false | MEDIUM diff --git a/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java b/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java index 962fb40..23672fa 100644 --- a/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java +++ b/connectors/camel-solrcloud-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrcloud/CamelSolrcloudSinkConnectorConfig.java @@ -39,7 +39,7 @@ public class CamelSolrcloudSinkConnectorConfig public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DOC = "maxConnectionsPerHost on the underlying HttpConnectionManager"; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DEFAULT = null; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_HTTP_CLIENT_CONF = "camel.sink.endpoint.httpClient"; - public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_HTTP_CLIENT_DOC = "Sets the http client to be used by the solrClient"; + public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_HTTP_CLIENT_DOC = "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set."; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_HTTP_CLIENT_DEFAULT = null; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer"; public static final String CAMEL_SINK_SOLRCLOUD_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 [...] @@ -54,7 +54,7 @@ public class CamelSolrcloudSinkConnectorConfig public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_REQUEST_HANDLER_DOC = "Set the request handler to be used"; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_REQUEST_HANDLER_DEFAULT = null; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_SOLR_CLIENT_CONF = "camel.sink.endpoint.solrClient"; - public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_SOLR_CLIENT_DOC = "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a co [...] + public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_SOLR_CLIENT_DOC = "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme i [...] public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_SOLR_CLIENT_DEFAULT = null; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_SO_TIMEOUT_CONF = "camel.sink.endpoint.soTimeout"; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_SO_TIMEOUT_DOC = "Sets the socket timeout on the SolrClient"; @@ -72,7 +72,7 @@ public class CamelSolrcloudSinkConnectorConfig public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ZK_CHROOT_DOC = "Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot')"; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ZK_CHROOT_DEFAULT = null; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ZK_HOST_CONF = "camel.sink.endpoint.zkHost"; - public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ZK_HOST_DOC = "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reaso [...] + public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ZK_HOST_DOC = "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this b [...] public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ZK_HOST_DEFAULT = null; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_CONF = "camel.sink.endpoint.allowCompression"; public static final String CAMEL_SINK_SOLRCLOUD_ENDPOINT_ALLOW_COMPRESSION_DOC = "Server side must support gzip or deflate for this to have any effect"; diff --git a/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json b/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json index 73d6d79..62c499a 100644 --- a/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json +++ b/connectors/camel-solrs-kafka-connector/src/generated/resources/camel-solrs-sink.json @@ -36,7 +36,7 @@ }, "camel.sink.endpoint.httpClient": { "name": "camel.sink.endpoint.httpClient", - "description": "Sets the http client to be used by the solrClient", + "description": "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set.", "priority": "MEDIUM", "required": "false" }, @@ -67,7 +67,7 @@ }, "camel.sink.endpoint.solrClient": { "name": "camel.sink.endpoint.solrClient", - "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or [...] + "description": "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the solr operation is INS [...] "priority": "MEDIUM", "required": "false" }, @@ -105,7 +105,7 @@ }, "camel.sink.endpoint.zkHost": { "name": "camel.sink.endpoint.zkHost", - "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124\/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123\/solr' or 'localhost:8123\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] + "description": "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182\/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181\/solr' or 'localhost:2181\/solr\/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot parameter).", "priority": "MEDIUM", "required": "false" }, diff --git a/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc b/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc index 41ce9a4..8587f6a 100644 --- a/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc +++ b/connectors/camel-solrs-kafka-connector/src/main/docs/camel-solrs-kafka-sink-connector.adoc @@ -35,18 +35,18 @@ The camel-solrs sink connector supports 22 options, which are listed below. | *camel.sink.endpoint.autoCommit* | If true, each producer operation will be automatically followed by a commit | false | false | MEDIUM | *camel.sink.endpoint.connectionTimeout* | Sets the connection timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost on the underlying HttpConnectionManager | null | false | LOW -| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient | null | false | MEDIUM +| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set. | 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.maxRetries* | Maximum number of retries to attempt in the event of transient errors | null | false | LOW | *camel.sink.endpoint.maxTotalConnections* | maxTotalConnection on the underlying HttpConnectionManager | null | false | LOW | *camel.sink.endpoint.requestHandler* | Set the request handler to be used | null | false | MEDIUM -| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme [...] +| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the sol [...] | *camel.sink.endpoint.soTimeout* | Sets the socket timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.streamingQueueSize* | Sets the queue size for the ConcurrentUpdateSolrClient | 10 | false | MEDIUM | *camel.sink.endpoint.streamingThreadCount* | Sets the number of threads for the ConcurrentUpdateSolrClient | 2 | false | MEDIUM | *camel.sink.endpoint.collection* | Set the default collection for SolrCloud | null | false | MEDIUM | *camel.sink.endpoint.zkChroot* | Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot') | null | false | MEDIUM -| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zk [...] +| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] | *camel.sink.endpoint.allowCompression* | Server side must support gzip or deflate for this to have any effect | null | false | MEDIUM | *camel.sink.endpoint.followRedirects* | Indicates whether redirects are used to get to the Solr server | null | false | MEDIUM | *camel.sink.endpoint.password* | Sets password for basic auth plugin enabled servers | null | false | MEDIUM diff --git a/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java b/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java index 8b2d757..f460280 100644 --- a/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java +++ b/connectors/camel-solrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java @@ -37,7 +37,7 @@ public class CamelSolrsSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_SOLRS_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DOC = "maxConnectionsPerHost on the underlying HttpConnectionManager"; public static final String CAMEL_SINK_SOLRS_ENDPOINT_DEFAULT_MAX_CONNECTIONS_PER_HOST_DEFAULT = null; public static final String CAMEL_SINK_SOLRS_ENDPOINT_HTTP_CLIENT_CONF = "camel.sink.endpoint.httpClient"; - public static final String CAMEL_SINK_SOLRS_ENDPOINT_HTTP_CLIENT_DOC = "Sets the http client to be used by the solrClient"; + public static final String CAMEL_SINK_SOLRS_ENDPOINT_HTTP_CLIENT_DOC = "Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set."; public static final String CAMEL_SINK_SOLRS_ENDPOINT_HTTP_CLIENT_DEFAULT = null; public static final String CAMEL_SINK_SOLRS_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer"; public static final String CAMEL_SINK_SOLRS_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 when [...] @@ -52,7 +52,7 @@ public class CamelSolrsSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_SOLRS_ENDPOINT_REQUEST_HANDLER_DOC = "Set the request handler to be used"; public static final String CAMEL_SINK_SOLRS_ENDPOINT_REQUEST_HANDLER_DEFAULT = null; public static final String CAMEL_SINK_SOLRS_ENDPOINT_SOLR_CLIENT_CONF = "camel.sink.endpoint.solrClient"; - public static final String CAMEL_SINK_SOLRS_ENDPOINT_SOLR_CLIENT_DOC = "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma) [...] + public static final String CAMEL_SINK_SOLRS_ENDPOINT_SOLR_CLIENT_DOC = "Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is no [...] public static final String CAMEL_SINK_SOLRS_ENDPOINT_SOLR_CLIENT_DEFAULT = null; public static final String CAMEL_SINK_SOLRS_ENDPOINT_SO_TIMEOUT_CONF = "camel.sink.endpoint.soTimeout"; public static final String CAMEL_SINK_SOLRS_ENDPOINT_SO_TIMEOUT_DOC = "Sets the socket timeout on the SolrClient"; @@ -70,7 +70,7 @@ public class CamelSolrsSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_SOLRS_ENDPOINT_ZK_CHROOT_DOC = "Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot')"; public static final String CAMEL_SINK_SOLRS_ENDPOINT_ZK_CHROOT_DEFAULT = null; public static final String CAMEL_SINK_SOLRS_ENDPOINT_ZK_HOST_CONF = "camel.sink.endpoint.zkHost"; - public static final String CAMEL_SINK_SOLRS_ENDPOINT_ZK_HOST_DOC = "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons ( [...] + public static final String CAMEL_SINK_SOLRS_ENDPOINT_ZK_HOST_DOC = "Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behav [...] public static final String CAMEL_SINK_SOLRS_ENDPOINT_ZK_HOST_DEFAULT = null; public static final String CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_CONF = "camel.sink.endpoint.allowCompression"; public static final String CAMEL_SINK_SOLRS_ENDPOINT_ALLOW_COMPRESSION_DOC = "Server side must support gzip or deflate for this to have any effect"; diff --git a/docs/modules/ROOT/pages/connectors/camel-hwcloud-functiongraph-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-hwcloud-functiongraph-kafka-sink-connector.adoc index 8d1b886..26cef89 100644 --- a/docs/modules/ROOT/pages/connectors/camel-hwcloud-functiongraph-kafka-sink-connector.adoc +++ b/docs/modules/ROOT/pages/connectors/camel-hwcloud-functiongraph-kafka-sink-connector.adoc @@ -34,7 +34,7 @@ The camel-hwcloud-functiongraph sink connector supports 17 options, which are li | *camel.sink.path.operation* | Operation to be performed | null | true | HIGH | *camel.sink.endpoint.endpoint* | FunctionGraph url. Carries higher precedence than region parameter based client initialization | null | false | MEDIUM | *camel.sink.endpoint.functionName* | Name of the function to invoke | null | false | MEDIUM -| *camel.sink.endpoint.functionPackage* | Functions that can be logically grouped together | null | false | MEDIUM +| *camel.sink.endpoint.functionPackage* | Functions that can be logically grouped together | "default" | 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.projectId* | Cloud project ID | null | true | HIGH | *camel.sink.endpoint.region* | FunctionGraph service region. This is lower precedence than endpoint based configuration | null | true | HIGH @@ -65,8 +65,4 @@ The camel-hwcloud-functiongraph sink connector has no transforms out of the box. The camel-hwcloud-functiongraph sink connector has no aggregation strategies out of the box. - - - - // kafka-connector options: END diff --git a/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc index cd883eb..5206298 100644 --- a/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc +++ b/docs/modules/ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc @@ -35,18 +35,18 @@ The camel-solr sink connector supports 22 options, which are listed below. | *camel.sink.endpoint.autoCommit* | If true, each producer operation will be automatically followed by a commit | false | false | MEDIUM | *camel.sink.endpoint.connectionTimeout* | Sets the connection timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost on the underlying HttpConnectionManager | null | false | LOW -| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient | null | false | MEDIUM +| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set. | 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.maxRetries* | Maximum number of retries to attempt in the event of transient errors | null | false | LOW | *camel.sink.endpoint.maxTotalConnections* | maxTotalConnection on the underlying HttpConnectionManager | null | false | LOW | *camel.sink.endpoint.requestHandler* | Set the request handler to be used | null | false | MEDIUM -| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme [...] +| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the sol [...] | *camel.sink.endpoint.soTimeout* | Sets the socket timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.streamingQueueSize* | Sets the queue size for the ConcurrentUpdateSolrClient | 10 | false | MEDIUM | *camel.sink.endpoint.streamingThreadCount* | Sets the number of threads for the ConcurrentUpdateSolrClient | 2 | false | MEDIUM | *camel.sink.endpoint.collection* | Set the default collection for SolrCloud | null | false | MEDIUM | *camel.sink.endpoint.zkChroot* | Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot') | null | false | MEDIUM -| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zk [...] +| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] | *camel.sink.endpoint.allowCompression* | Server side must support gzip or deflate for this to have any effect | null | false | MEDIUM | *camel.sink.endpoint.followRedirects* | Indicates whether redirects are used to get to the Solr server | null | false | MEDIUM | *camel.sink.endpoint.password* | Sets password for basic auth plugin enabled servers | null | false | MEDIUM @@ -70,8 +70,4 @@ The camel-solr sink connector has no transforms out of the box. The camel-solr sink connector has no aggregation strategies out of the box. - - - - // kafka-connector options: END diff --git a/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc index b0a0277..9fed037 100644 --- a/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc +++ b/docs/modules/ROOT/pages/connectors/camel-solrCloud-kafka-sink-connector.adoc @@ -35,18 +35,18 @@ The camel-solrCloud sink connector supports 22 options, which are listed below. | *camel.sink.endpoint.autoCommit* | If true, each producer operation will be automatically followed by a commit | false | false | MEDIUM | *camel.sink.endpoint.connectionTimeout* | Sets the connection timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost on the underlying HttpConnectionManager | null | false | LOW -| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient | null | false | MEDIUM +| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set. | 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.maxRetries* | Maximum number of retries to attempt in the event of transient errors | null | false | LOW | *camel.sink.endpoint.maxTotalConnections* | maxTotalConnection on the underlying HttpConnectionManager | null | false | LOW | *camel.sink.endpoint.requestHandler* | Set the request handler to be used | null | false | MEDIUM -| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme [...] +| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the sol [...] | *camel.sink.endpoint.soTimeout* | Sets the socket timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.streamingQueueSize* | Sets the queue size for the ConcurrentUpdateSolrClient | 10 | false | MEDIUM | *camel.sink.endpoint.streamingThreadCount* | Sets the number of threads for the ConcurrentUpdateSolrClient | 2 | false | MEDIUM | *camel.sink.endpoint.collection* | Set the default collection for SolrCloud | null | false | MEDIUM | *camel.sink.endpoint.zkChroot* | Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot') | null | false | MEDIUM -| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zk [...] +| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] | *camel.sink.endpoint.allowCompression* | Server side must support gzip or deflate for this to have any effect | null | false | MEDIUM | *camel.sink.endpoint.followRedirects* | Indicates whether redirects are used to get to the Solr server | null | false | MEDIUM | *camel.sink.endpoint.password* | Sets password for basic auth plugin enabled servers | null | false | MEDIUM @@ -70,8 +70,4 @@ The camel-solrCloud sink connector has no transforms out of the box. The camel-solrCloud sink connector has no aggregation strategies out of the box. - - - - // kafka-connector options: END diff --git a/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc index 18ff664..8587f6a 100644 --- a/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc +++ b/docs/modules/ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc @@ -35,18 +35,18 @@ The camel-solrs sink connector supports 22 options, which are listed below. | *camel.sink.endpoint.autoCommit* | If true, each producer operation will be automatically followed by a commit | false | false | MEDIUM | *camel.sink.endpoint.connectionTimeout* | Sets the connection timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.defaultMaxConnectionsPerHost* | maxConnectionsPerHost on the underlying HttpConnectionManager | null | false | LOW -| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient | null | false | MEDIUM +| *camel.sink.endpoint.httpClient* | Sets the http client to be used by the solrClient. This is only applicable when solrClient is not set. | 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.maxRetries* | Maximum number of retries to attempt in the event of transient errors | null | false | LOW | *camel.sink.endpoint.maxTotalConnections* | maxTotalConnection on the underlying HttpConnectionManager | null | false | LOW | *camel.sink.endpoint.requestHandler* | Set the request handler to be used | null | false | MEDIUM -| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient. A CloudSolrClient should point to a zookeeper endpoint. Other clients point to a Solr endpoint. 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme [...] +| *camel.sink.endpoint.solrClient* | Uses the provided solr client to connect to solr. When this parameter is not specified, camel applies the following rules to determine the SolrClient: 1) when zkHost or zkChroot (=zookeeper root) parameter is set, then the CloudSolrClient is used. 2) when multiple hosts are specified in the uri (separated with a comma), then the CloudSolrClient (uri scheme is 'solrCloud') or the LBHttpSolrClient (uri scheme is not 'solrCloud') is used. 3) when the sol [...] | *camel.sink.endpoint.soTimeout* | Sets the socket timeout on the SolrClient | null | false | MEDIUM | *camel.sink.endpoint.streamingQueueSize* | Sets the queue size for the ConcurrentUpdateSolrClient | 10 | false | MEDIUM | *camel.sink.endpoint.streamingThreadCount* | Sets the number of threads for the ConcurrentUpdateSolrClient | 2 | false | MEDIUM | *camel.sink.endpoint.collection* | Set the default collection for SolrCloud | null | false | MEDIUM | *camel.sink.endpoint.zkChroot* | Set the chroot of the zookeeper connection (include the leading slash; e.g. '/mychroot') | null | false | MEDIUM -| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:8123,localhost:8124. Optionally add the chroot, e.g. zkHost=localhost:8123,localhost:8124/rootformysolr. In case the first part of the chroot path in the zkHost parameter is set to 'solr' (e.g. 'localhost:8123/solr' or 'localhost:8123/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zk [...] +| *camel.sink.endpoint.zkHost* | Set the ZooKeeper host(s) urls which the CloudSolrClient uses, e.g. zkHost=localhost:2181,localhost:2182. Optionally add the chroot, e.g. zkHost=localhost:2181,localhost:2182/rootformysolr. In case the first part of the url path (='contextroot') is set to 'solr' (e.g. 'localhost:2181/solr' or 'localhost:2181/solr/..'), then that path is not considered as zookeeper chroot for backward compatibility reasons (this behaviour can be overridden via zkChroot par [...] | *camel.sink.endpoint.allowCompression* | Server side must support gzip or deflate for this to have any effect | null | false | MEDIUM | *camel.sink.endpoint.followRedirects* | Indicates whether redirects are used to get to the Solr server | null | false | MEDIUM | *camel.sink.endpoint.password* | Sets password for basic auth plugin enabled servers | null | false | MEDIUM @@ -70,8 +70,4 @@ The camel-solrs sink connector has no transforms out of the box. The camel-solrs sink connector has no aggregation strategies out of the box. - - - - // kafka-connector options: END