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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 2d8da0b [create-pull-request] automated change
2d8da0b is described below
commit 2d8da0b7b03726b2ef6c3587e146234b2aecc4b9
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Sep 22 00:45:03 2021 +0000
[create-pull-request] automated change
---
.../camel/springboot/catalog/components.properties | 1 +
.../camel/springboot/catalog/components/file.json | 2 +-
.../camel/springboot/catalog/components/ftp.json | 2 +-
.../camel/springboot/catalog/components/ftps.json | 2 +-
.../components/hwcloud-imagerecognition.json | 48 ++++++++++++++++++++++
.../camel/springboot/catalog/components/kafka.json | 6 +--
.../springboot/catalog/components/salesforce.json | 6 +--
.../camel/springboot/catalog/components/sftp.json | 2 +-
components-starter/README.adoc | 6 ++-
.../docs/huaweicloud-imagerecognition-starter.adoc | 8 ++--
...ImageRecognitionComponentAutoConfiguration.java | 4 +-
.../ImageRecognitionComponentConfiguration.java | 6 +--
.../src/main/docs/kafka-starter.adoc | 5 +--
.../springboot/KafkaComponentConfiguration.java | 15 +------
.../src/main/docs/salesforce-starter.adoc | 4 +-
.../SalesforceComponentConfiguration.java | 10 ++---
.../huaweicloud-imagerecognition-starter.adoc | 8 ++--
docs/modules/ROOT/pages/kafka-starter.adoc | 5 +--
docs/modules/ROOT/pages/list.adoc | 4 +-
docs/modules/ROOT/pages/salesforce-starter.adoc | 4 +-
20 files changed, 91 insertions(+), 57 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
index 7474ec2..4aa230a 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
@@ -151,6 +151,7 @@ hwcloud-dms
hwcloud-functiongraph
hwcloud-iam
hwcloud-image
+hwcloud-imagerecognition
hwcloud-obs
hwcloud-smn
iec60870-client
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
index d246d73..1184f5f 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
@@ -82,7 +82,7 @@
"filterFile": { "kind": "parameter", "displayName": "Filter File",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Filters the file based on Simple
language. For example to filter on file size, you can use ${file:size} 5000" },
"idempotent": { "kind": "parameter", "displayName": "Idempotent", "group":
"filter", "label": "consumer,filter", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "false", "description": "Option to use the
Idempotent Consumer EIP pattern to let Camel skip already processed files. Will
by default use a memory based LRUCache that holds 1000 entries. If noop=true
then idempotent will be enable [...]
"idempotentKey": { "kind": "parameter", "displayName": "Idempotent Key",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom idempotent key. By
default the absolute path of the file is used. You can use the File Language,
for example to use the file name and file size, you can do:
idempotentKey=${file:name}-${file:size}" },
- "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryMessageIdRepository if none is specified and idempotent is true." },
+ "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryIdempotentRepository if none is specified and idempotent is true." },
"include": { "kind": "parameter", "displayName": "Include", "group":
"filter", "label": "consumer,filter", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Is used to include files, if filename matches
the regex pattern (matching is case in-sensitive). Notice if you use symbols
such as plus sign and others you would need to configure this using the RAW()
syntax if configuring this as an endp [...]
"includeExt": { "kind": "parameter", "displayName": "Include Ext",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Is used to include files matching file
extension name (case insensitive). For example to include txt files, then use
includeExt=txt. Multiple extensions can be separated by comma, for example to
include txt and xml files, use inclu [...]
"maxDepth": { "kind": "parameter", "displayName": "Max Depth", "group":
"filter", "label": "consumer,filter", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "description": "The maximum depth to traverse when
recursively processing a directory." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftp.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftp.json
index c64ab7f..9eb93df 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftp.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftp.json
@@ -105,7 +105,7 @@
"filterFile": { "kind": "parameter", "displayName": "Filter File",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Filters the file based on Simple
language. For example to filter on file size, you can use ${file:size} 5000" },
"idempotent": { "kind": "parameter", "displayName": "Idempotent", "group":
"filter", "label": "consumer,filter", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "false", "description": "Option to use the
Idempotent Consumer EIP pattern to let Camel skip already processed files. Will
by default use a memory based LRUCache that holds 1000 entries. If noop=true
then idempotent will be enable [...]
"idempotentKey": { "kind": "parameter", "displayName": "Idempotent Key",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom idempotent key. By
default the absolute path of the file is used. You can use the File Language,
for example to use the file name and file size, you can do:
idempotentKey=${file:name}-${file:size}" },
- "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryMessageIdRepository if none is specified and idempotent is true." },
+ "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryIdempotentRepository if none is specified and idempotent is true." },
"include": { "kind": "parameter", "displayName": "Include", "group":
"filter", "label": "consumer,filter", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Is used to include files, if filename matches
the regex pattern (matching is case in-sensitive). Notice if you use symbols
such as plus sign and others you would need to configure this using the RAW()
syntax if configuring this as an endp [...]
"includeExt": { "kind": "parameter", "displayName": "Include Ext",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Is used to include files matching file
extension name (case insensitive). For example to include txt files, then use
includeExt=txt. Multiple extensions can be separated by comma, for example to
include txt and xml files, use inclu [...]
"maxDepth": { "kind": "parameter", "displayName": "Max Depth", "group":
"filter", "label": "consumer,filter", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "description": "The maximum depth to traverse when
recursively processing a directory." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftps.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftps.json
index 74e3f82..6fe52b2 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftps.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ftps.json
@@ -106,7 +106,7 @@
"filterFile": { "kind": "parameter", "displayName": "Filter File",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Filters the file based on Simple
language. For example to filter on file size, you can use ${file:size} 5000" },
"idempotent": { "kind": "parameter", "displayName": "Idempotent", "group":
"filter", "label": "consumer,filter", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "false", "description": "Option to use the
Idempotent Consumer EIP pattern to let Camel skip already processed files. Will
by default use a memory based LRUCache that holds 1000 entries. If noop=true
then idempotent will be enable [...]
"idempotentKey": { "kind": "parameter", "displayName": "Idempotent Key",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom idempotent key. By
default the absolute path of the file is used. You can use the File Language,
for example to use the file name and file size, you can do:
idempotentKey=${file:name}-${file:size}" },
- "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryMessageIdRepository if none is specified and idempotent is true." },
+ "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryIdempotentRepository if none is specified and idempotent is true." },
"include": { "kind": "parameter", "displayName": "Include", "group":
"filter", "label": "consumer,filter", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Is used to include files, if filename matches
the regex pattern (matching is case in-sensitive). Notice if you use symbols
such as plus sign and others you would need to configure this using the RAW()
syntax if configuring this as an endp [...]
"includeExt": { "kind": "parameter", "displayName": "Include Ext",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Is used to include files matching file
extension name (case insensitive). For example to include txt files, then use
includeExt=txt. Multiple extensions can be separated by comma, for example to
include txt and xml files, use inclu [...]
"maxDepth": { "kind": "parameter", "displayName": "Max Depth", "group":
"filter", "label": "consumer,filter", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "description": "The maximum depth to traverse when
recursively processing a directory." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/hwcloud-imagerecognition.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/hwcloud-imagerecognition.json
new file mode 100644
index 0000000..69166bd
--- /dev/null
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/hwcloud-imagerecognition.json
@@ -0,0 +1,48 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "hwcloud-imagerecognition",
+ "title": "Huawei Cloud Image Recognition",
+ "description": "To identify objects, scenes, and concepts in images on
Huawei Cloud",
+ "deprecated": false,
+ "firstVersion": "3.12.0",
+ "label": "cloud,messaging",
+ "javaType":
"org.apache.camel.component.huaweicloud.image.ImageRecognitionComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel.springboot",
+ "artifactId": "camel-huaweicloud-imagerecognition-starter",
+ "version": "3.12.0-SNAPSHOT",
+ "scheme": "hwcloud-imagerecognition",
+ "extendsScheme": "",
+ "syntax": "hwcloud-imagerecognition:operation",
+ "async": false,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": true,
+ "lenientProperties": false
+ },
+ "componentProperties": {
+ "lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
+ "autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ },
+ "properties": {
+ "operation": { "kind": "path", "displayName": "Operation name", "group":
"producer", "label": "producer", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Name of Image Recognition
operation to perform, including celebrityRecognition and tagRecognition" },
+ "accessKey": { "kind": "parameter", "displayName": "Account access key
(AK)", "group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": true, "description": "Access key for the cloud
user" },
+ "endpoint": { "kind": "parameter", "displayName": "Service endpoint",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Fully qualified Image
Recognition service url. Carries higher precedence than region based
configuration." },
+ "imageContent": { "kind": "parameter", "displayName": "imageContent",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Indicates the Base64
character string converted from the image. The size cannot exceed 10 MB. The
image resolution of the narrow sides must be greater than 15 pixels, and that
of the wide sides cannot exceed 4096 pixel [...]
+ "imageUrl": { "kind": "parameter", "displayName": "imageUrl", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Indicates the URL of an image. The
options are as follows: HTTP\/HTTPS URLs on the public network OBS URLs. To use
OBS data, authorization is required, including service authorization, temporary
authorization, and anonymous pu [...]
+ "lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during sta [...]
+ "projectId": { "kind": "parameter", "displayName": "Project ID", "group":
"producer", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Cloud project ID" },
+ "proxyHost": { "kind": "parameter", "displayName": "Proxy server host",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Proxy server ip\/hostname"
},
+ "proxyPassword": { "kind": "parameter", "displayName": "Proxy password",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": true, "description": "Proxy authentication
password" },
+ "proxyPort": { "kind": "parameter", "displayName": "Proxy server port",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Proxy server port" },
+ "proxyUser": { "kind": "parameter", "displayName": "Proxy user", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": true, "description": "Proxy authentication user" },
+ "region": { "kind": "parameter", "displayName": "Service region", "group":
"producer", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Image Recognition service region.
Currently only cn-north-1 and cn-north-4 are supported. This is lower
precedence than endpoint based configuration." },
+ "secretKey": { "kind": "parameter", "displayName": "Account secret key
(SK)", "group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": true, "description": "Secret key for the cloud
user" },
+ "serviceKeys": { "kind": "parameter", "displayName": "Service
Configuration", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.huaweicloud.common.models.ServiceKeys",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret": true,
"description": "Configuration object for cloud service authentication" },
+ "tagLanguage": { "kind": "parameter", "displayName": "tagLanguage",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": "zh", "description":
"Indicates the language of the returned tags when the operation is
tagRecognition, including zh and en." },
+ "tagLimit": { "kind": "parameter", "displayName": "tagLimit", "group":
"producer", "label": "", "required": false, "type": "integer", "javaType":
"int", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "defaultValue": 50, "description": "Indicates the maximum
number of the returned tags when the operation is tagRecognition." },
+ "threshold": { "kind": "parameter", "displayName": "threshold", "group":
"producer", "label": "", "required": false, "type": "number", "javaType":
"float", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Indicates the threshold of confidence. When
the operation is tagRecognition, this parameter ranges from 0 to 100. Tags
whose confidence score is lower than the threshold will not be returned. The
default value is 60. When the operation [...]
+ "ignoreSslVerification": { "kind": "parameter", "displayName": "SSL
Verification Ignored", "group": "security", "label": "security", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
false, "description": "Ignore SSL verification" }
+ }
+}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
index eed52f6..0806af5 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
@@ -39,8 +39,7 @@
"checkCrcs": { "kind": "property", "displayName": "Check Crcs", "group":
"consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Automatically check the CRC32 of the records
consumed. This ensures no on-the-wire or on-disk cor [...]
"commitTimeoutMs": { "kind": "property", "displayName": "Commit Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "java.lang.Long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum time, in milliseconds, that the
code will wait for a synchronous commit to [...]
"consumerRequestTimeoutMs": { "kind": "property", "displayName": "Consumer
Request Timeout Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "40000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client [...]
- "consumersCount": { "kind": "property", "displayName": "Consumers Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 1, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of consumers that connect to kafka
server" },
- "consumerStreams": { "kind": "property", "displayName": "Consumer
Streams", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Number of concurrent consumers on the
consumer" },
+ "consumersCount": { "kind": "property", "displayName": "Consumers Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 1, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of consumers that connect to kafka
server. Each consumer is run on a separate thread, that retr [...]
"fetchMaxBytes": { "kind": "property", "displayName": "Fetch Max Bytes",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "52428800", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data the server should
return for a fetch request This is not [...]
"fetchMinBytes": { "kind": "property", "displayName": "Fetch Min Bytes",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The minimum amount of data the server should
return for a fetch request. If insufficient da [...]
"fetchWaitMaxMs": { "kind": "property", "displayName": "Fetch Wait Max
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "500", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of time the server will
block before answering the fetch request if [...]
@@ -145,8 +144,7 @@
"checkCrcs": { "kind": "parameter", "displayName": "Check Crcs", "group":
"consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Automatically check the CRC32 of the records
consumed. This ensures no on-the-wire or on-disk co [...]
"commitTimeoutMs": { "kind": "parameter", "displayName": "Commit Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "java.lang.Long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum time, in milliseconds, that the
code will wait for a synchronous commit t [...]
"consumerRequestTimeoutMs": { "kind": "parameter", "displayName":
"Consumer Request Timeout Ms", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"40000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls the maximum amount
of time the clien [...]
- "consumersCount": { "kind": "parameter", "displayName": "Consumers Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 1, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of consumers that connect to kafka
server" },
- "consumerStreams": { "kind": "parameter", "displayName": "Consumer
Streams", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Number of concurrent consumers on the
consumer" },
+ "consumersCount": { "kind": "parameter", "displayName": "Consumers Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 1, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of consumers that connect to kafka
server. Each consumer is run on a separate thread, that ret [...]
"fetchMaxBytes": { "kind": "parameter", "displayName": "Fetch Max Bytes",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "52428800", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data the server should
return for a fetch request This is not [...]
"fetchMinBytes": { "kind": "parameter", "displayName": "Fetch Min Bytes",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The minimum amount of data the server should
return for a fetch request. If insufficient d [...]
"fetchWaitMaxMs": { "kind": "parameter", "displayName": "Fetch Wait Max
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "500", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of time the server will
block before answering the fetch request i [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/salesforce.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/salesforce.json
index efad575..b1cc560 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/salesforce.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/salesforce.json
@@ -30,7 +30,7 @@
"batchId": { "kind": "property", "displayName": "Batch Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Bulk API Batch ID" },
"contentType": { "kind": "property", "displayName": "Content Type",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.salesforce.api.dto.bulk.ContentType",
"enum": [ "XML", "CSV", "JSON", "ZIP_XML", "ZIP_CSV", "ZIP_JSON" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Bulk API co [...]
"defaultReplayId": { "kind": "property", "displayName": "Default Replay
Id", "group": "common", "label": "", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "-1", "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Default replayId setting if no
value is found in initialReplayIdMap" },
- "format": { "kind": "property", "displayName": "Format", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.salesforce.internal.PayloadFormat", "enum": [
"JSON", "XML" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Payload format to use for
Salesforce API calls, either JSON or XM [...]
+ "format": { "kind": "property", "displayName": "Format", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.salesforce.internal.PayloadFormat", "enum": [
"JSON", "XML" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Payload format to use for
Salesforce API calls, either JSON or XM [...]
"httpClient": { "kind": "property", "displayName": "Http Client", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.salesforce.SalesforceHttpClient", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Custom Jetty Http Client to use
to connect to Salesforce." },
"httpClientConnectionTimeout": { "kind": "property", "displayName": "Http
Client Connection Timeout", "group": "common", "label": "common", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 60000, "description": "Connection
timeout used by the HttpClient when connecting to the Salesforce server." },
"httpClientIdleTimeout": { "kind": "property", "displayName": "Http Client
Idle Timeout", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10000, "description": "Timeout used by the
HttpClient when waiting for response from the Salesforce server." },
@@ -50,7 +50,7 @@
"notifyForOperationUndelete": { "kind": "property", "displayName": "Notify
For Operation Undelete", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Notify for un-delete operation,
defaults to false (API version = 29.0)" },
"notifyForOperationUpdate": { "kind": "property", "displayName": "Notify
For Operation Update", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Notify for update operation,
defaults to false (API version = 29.0)" },
"objectMapper": { "kind": "property", "displayName": "Object Mapper",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "com.fasterxml.jackson.databind.ObjectMapper", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Custom Jackson ObjectMapper to
use when serializing\/deserializing Salesforce objects." },
- "packages": { "kind": "property", "displayName": "Packages", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"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 SO [...]
+ "packages": { "kind": "property", "displayName": "Packages", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"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. Multip [...]
"pkChunking": { "kind": "property", "displayName": "Pk Chunking", "group":
"common", "label": "", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Use PK Chunking. Only for use
in original Bulk API. Bulk 2.0 API performs PK chunking automatically, if
necessary." },
"pkChunkingChunkSize": { "kind": "property", "displayName": "Pk Chunking
Chunk Size", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Chunk size for use with PK
Chunking. If unspecified, salesforce default is 100,000. Maximum size is
250,000." },
"pkChunkingParent": { "kind": "property", "displayName": "Pk Chunking
Parent", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "config", "description": "Specifies the parent object
when you're enabling PK chunking for queries on sharing objects. The chunks are
based [...]
@@ -121,7 +121,7 @@
"batchId": { "kind": "parameter", "displayName": "Batch Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Bulk API Batch ID" },
"contentType": { "kind": "parameter", "displayName": "Content Type",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.salesforce.api.dto.bulk.ContentType",
"enum": [ "XML", "CSV", "JSON", "ZIP_XML", "ZIP_CSV", "ZIP_JSON" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Bul [...]
"defaultReplayId": { "kind": "parameter", "displayName": "Default Replay
Id", "group": "common", "label": "", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "-1", "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Default replayId setting
if no value is found in initialReplayIdMap" },
- "format": { "kind": "parameter", "displayName": "Format", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.salesforce.internal.PayloadFormat", "enum": [
"JSON", "XML" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Payload format to use
for Salesforce API calls, either JS [...]
+ "format": { "kind": "parameter", "displayName": "Format", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.salesforce.internal.PayloadFormat", "enum": [
"JSON", "XML" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Payload format to use
for Salesforce API calls, either JS [...]
"httpClient": { "kind": "parameter", "displayName": "Http Client",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.salesforce.SalesforceHttpClient",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Custom Jetty Http Client
to use to connect to Salesforce." },
"includeDetails": { "kind": "parameter", "displayName": "Include Details",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Include details in
Salesforce1 Analytics report, defaults to false." },
"initialReplayIdMap": { "kind": "parameter", "displayName": "Initial
Replay Id Map", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "java.util.Map<java.lang.String, java.lang.Long>",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.salesforce.SalesforceEndpointConfig",
"configurationField": "configuration", "description": "Replay IDs to start from
per channel name." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
index 07ea58f..f1704f1 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
@@ -100,7 +100,7 @@
"filterFile": { "kind": "parameter", "displayName": "Filter File",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Filters the file based on Simple
language. For example to filter on file size, you can use ${file:size} 5000" },
"idempotent": { "kind": "parameter", "displayName": "Idempotent", "group":
"filter", "label": "consumer,filter", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "false", "description": "Option to use the
Idempotent Consumer EIP pattern to let Camel skip already processed files. Will
by default use a memory based LRUCache that holds 1000 entries. If noop=true
then idempotent will be enable [...]
"idempotentKey": { "kind": "parameter", "displayName": "Idempotent Key",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom idempotent key. By
default the absolute path of the file is used. You can use the File Language,
for example to use the file name and file size, you can do:
idempotentKey=${file:name}-${file:size}" },
- "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryMessageIdRepository if none is specified and idempotent is true." },
+ "idempotentRepository": { "kind": "parameter", "displayName": "Idempotent
Repository", "group": "filter", "label": "consumer,filter", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.IdempotentRepository",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable repository org.apache.camel.spi.IdempotentRepository which by default
use MemoryIdempotentRepository if none is specified and idempotent is true." },
"include": { "kind": "parameter", "displayName": "Include", "group":
"filter", "label": "consumer,filter", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Is used to include files, if filename matches
the regex pattern (matching is case in-sensitive). Notice if you use symbols
such as plus sign and others you would need to configure this using the RAW()
syntax if configuring this as an endp [...]
"includeExt": { "kind": "parameter", "displayName": "Include Ext",
"group": "filter", "label": "consumer,filter", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Is used to include files matching file
extension name (case insensitive). For example to include txt files, then use
includeExt=txt. Multiple extensions can be separated by comma, for example to
include txt and xml files, use inclu [...]
"maxDepth": { "kind": "parameter", "displayName": "Max Depth", "group":
"filter", "label": "consumer,filter", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "description": "The maximum depth to traverse when
recursively processing a directory." },
diff --git a/components-starter/README.adoc b/components-starter/README.adoc
index 6e91811..2afe35b 100644
--- a/components-starter/README.adoc
+++ b/components-starter/README.adoc
@@ -5,7 +5,7 @@ Apache Camel Spring Boot supports the following Camel artifacts
as Spring Boot S
== Camel Components
// components: START
-Number of Camel components: 338 in 274 JAR artifacts (1 deprecated)
+Number of Camel components: 339 in 274 JAR artifacts (1 deprecated)
[width="100%",cols="4,3,3,3,6",options="header"]
|===
@@ -293,7 +293,9 @@ Number of Camel components: 338 in 274 JAR artifacts (1
deprecated)
| xref:latest@components::http-component.adoc[HTTP] | camel-http-starter |
Stable | 2.3 | Send requests to external HTTP servers using Apache HTTP Client
4.x.
-| xref:latest@components::huaweicloud-imagerecognition-starter.adoc[Huawei
Cloud Image Recognition] | camel-hwcloud-imagerecognition-starter | Preview |
3.12 | To identify objects, scenes, and concepts in images on Huawei Cloud
+| xref:latest@components::hwcloud-image-component.adoc[Huawei Cloud Image
Recognition] | camel-huaweicloud-imagerecognition-starter | Preview | 3.12 | To
identify objects, scenes, and concepts in images on Huawei Cloud
+
+| xref:latest@components::hwcloud-imagerecognition-component.adoc[Huawei Cloud
Image Recognition] | camel-huaweicloud-imagerecognition-starter | Preview |
3.12 | To identify objects, scenes, and concepts in images on Huawei Cloud
| xref:latest@components::hwcloud-dms-component.adoc[Huawei Distributed
Message Service (DMS)] | camel-huaweicloud-dms-starter | Preview | 3.12 | To
integrate with a fully managed, high-performance message queuing service on
Huawei Cloud
diff --git
a/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/docs/huaweicloud-imagerecognition-starter.adoc
b/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/docs/huaweicloud-imagerecognition-starter.adoc
index c86d072..2b4565d 100644
---
a/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/docs/huaweicloud-imagerecognition-starter.adoc
+++
b/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/docs/huaweicloud-imagerecognition-starter.adoc
@@ -24,10 +24,8 @@ The component supports 3 options, which are listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *camel.component.hwcloud-image.autowired-enabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | Boolean
-| *camel.component.hwcloud-image.enabled* | Whether to enable auto
configuration of the hwcloud-image component. This is enabled by default. | |
Boolean
-| *camel.component.hwcloud-image.lazy-start-producer* | 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 proces [...]
+| *camel.component.hwcloud-imagerecognition.autowired-enabled* | Whether
autowiring is enabled. This is used for automatic autowiring options (the
option must be marked as autowired) by looking up in the registry to find if
there is a single instance of matching type, which then gets configured on the
component. This can be used for automatic configuring JDBC data sources, JMS
connection factories, AWS Clients, etc. | true | Boolean
+| *camel.component.hwcloud-imagerecognition.enabled* | Whether to enable auto
configuration of the hwcloud-imagerecognition component. This is enabled by
default. | | Boolean
+| *camel.component.hwcloud-imagerecognition.lazy-start-producer* | 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 messag [...]
|===
-
-
// spring-boot-auto-configure options: END
diff --git
a/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentAutoConfiguration.java
b/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentAutoConfiguration.java
index 3479870..79b0d98 100644
---
a/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentAutoConfiguration.java
+++
b/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentAutoConfiguration.java
@@ -43,7 +43,7 @@ import org.springframework.context.annotation.Lazy;
@Configuration(proxyBeanMethods = false)
@Conditional(ConditionalOnCamelContextAndAutoConfigurationBeans.class)
@EnableConfigurationProperties({ComponentConfigurationProperties.class,ImageRecognitionComponentConfiguration.class})
-@ConditionalOnHierarchicalProperties({"camel.component",
"camel.component.hwcloud-image"})
+@ConditionalOnHierarchicalProperties({"camel.component",
"camel.component.hwcloud-imagerecognition"})
@AutoConfigureAfter(CamelAutoConfiguration.class)
public class ImageRecognitionComponentAutoConfiguration {
@@ -71,7 +71,7 @@ public class ImageRecognitionComponentAutoConfiguration {
return HierarchicalPropertiesEvaluator.evaluate(
applicationContext,
"camel.component.customizer",
- "camel.component.hwcloud-image.customizer")
+ "camel.component.hwcloud-imagerecognition.customizer")
&& target instanceof ImageRecognitionComponent;
}
};
diff --git
a/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentConfiguration.java
b/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentConfiguration.java
index 507ca9f..23f1302 100644
---
a/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentConfiguration.java
+++
b/components-starter/camel-huaweicloud-imagerecognition-starter/src/main/java/org/apache/camel/component/huaweicloud/image/springboot/ImageRecognitionComponentConfiguration.java
@@ -26,14 +26,14 @@ import
org.springframework.boot.context.properties.ConfigurationProperties;
* Generated by camel-package-maven-plugin - do not edit this file!
*/
@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
-@ConfigurationProperties(prefix = "camel.component.hwcloud-image")
+@ConfigurationProperties(prefix = "camel.component.hwcloud-imagerecognition")
public class ImageRecognitionComponentConfiguration
extends
ComponentConfigurationPropertiesCommon {
/**
- * Whether to enable auto configuration of the hwcloud-image component.
This
- * is enabled by default.
+ * Whether to enable auto configuration of the hwcloud-imagerecognition
+ * component. This is enabled by default.
*/
private Boolean enabled;
/**
diff --git
a/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
b/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
index c8bd529..3e090c0 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
@@ -17,7 +17,7 @@ When using kafka with Spring Boot make sure to use the
following Maven dependenc
----
-The component supports 105 options, which are listed below.
+The component supports 104 options, which are listed below.
@@ -42,8 +42,7 @@ The component supports 105 options, which are listed below.
| *camel.component.kafka.configuration* | Allows to pre-configure the Kafka
component with common options that the endpoints will reuse. The option is a
org.apache.camel.component.kafka.KafkaConfiguration type. | |
KafkaConfiguration
| *camel.component.kafka.connection-max-idle-ms* | Close idle connections
after the number of milliseconds specified by this config. | 540000 | Integer
| *camel.component.kafka.consumer-request-timeout-ms* | The configuration
controls the maximum amount of time the client will wait for the response of a
request. If the response is not received before the timeout elapses the client
will resend the request if necessary or fail the request if retries are
exhausted. | 40000 | Integer
-| *camel.component.kafka.consumer-streams* | Number of concurrent consumers on
the consumer | 10 | Integer
-| *camel.component.kafka.consumers-count* | The number of consumers that
connect to kafka server | 1 | Integer
+| *camel.component.kafka.consumers-count* | The number of consumers that
connect to kafka server. Each consumer is run on a separate thread, that
retrieves and process the incoming data. | 1 | Integer
| *camel.component.kafka.delivery-timeout-ms* | An upper bound on the time to
report success or failure after a call to send() returns. This limits the total
time that a record will be delayed prior to sending, the time to await
acknowledgement from the broker (if expected), and the time allowed for
retriable send failures. | 120000 | Integer
| *camel.component.kafka.enable-idempotence* | If set to 'true' the producer
will ensure that exactly one copy of each message is written in the stream. If
'false', producer retries may write duplicates of the retried message in the
stream. If set to true this option will require
max.in.flight.requests.per.connection to be set to 1 and retries cannot be zero
and additionally acks must be set to 'all'. | false | Boolean
| *camel.component.kafka.enabled* | Whether to enable auto configuration of
the kafka component. This is enabled by default. | | Boolean
diff --git
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index 48c60d6..86b0077 100644
---
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -165,14 +165,11 @@ public class KafkaComponentConfiguration
*/
private Integer consumerRequestTimeoutMs = 40000;
/**
- * The number of consumers that connect to kafka server
+ * The number of consumers that connect to kafka server. Each consumer is
+ * run on a separate thread, that retrieves and process the incoming data.
*/
private Integer consumersCount = 1;
/**
- * Number of concurrent consumers on the consumer
- */
- private Integer consumerStreams = 10;
- /**
* The maximum amount of data the server should return for a fetch request
* This is not an absolute maximum, if the first message in the first
* non-empty partition of the fetch is larger than this value, the message
@@ -897,14 +894,6 @@ public class KafkaComponentConfiguration
this.consumersCount = consumersCount;
}
- public Integer getConsumerStreams() {
- return consumerStreams;
- }
-
- public void setConsumerStreams(Integer consumerStreams) {
- this.consumerStreams = consumerStreams;
- }
-
public Integer getFetchMaxBytes() {
return fetchMaxBytes;
}
diff --git
a/components-starter/camel-salesforce-starter/src/main/docs/salesforce-starter.adoc
b/components-starter/camel-salesforce-starter/src/main/docs/salesforce-starter.adoc
index 48c201f..f48ab03 100644
---
a/components-starter/camel-salesforce-starter/src/main/docs/salesforce-starter.adoc
+++
b/components-starter/camel-salesforce-starter/src/main/docs/salesforce-starter.adoc
@@ -41,7 +41,7 @@ The component supports 88 options, which are listed below.
| *camel.component.salesforce.content-type* | Bulk API content type, one of
XML, CSV, ZIP_XML, ZIP_CSV | | ContentType
| *camel.component.salesforce.default-replay-id* | Default replayId setting if
no value is found in initialReplayIdMap | -1 | Long
| *camel.component.salesforce.enabled* | Whether to enable auto configuration
of the salesforce component. This is enabled by default. | | Boolean
-| *camel.component.salesforce.format* | Payload format to use for Salesforce
API calls, either JSON or XML, defaults to JSON | | PayloadFormat
+| *camel.component.salesforce.format* | Payload format to use for Salesforce
API calls, either JSON or XML, defaults to JSON. As of Camel 3.12, this option
only applies to the Raw operation. | | PayloadFormat
| *camel.component.salesforce.http-client* | Custom Jetty Http Client to use
to connect to Salesforce. The option is a
org.apache.camel.component.salesforce.SalesforceHttpClient type. | |
SalesforceHttpClient
| *camel.component.salesforce.http-client-connection-timeout* | Connection
timeout used by the HttpClient when connecting to the Salesforce server. |
60000 | Long
| *camel.component.salesforce.http-client-idle-timeout* | Timeout used by the
HttpClient when waiting for response from the Salesforce server. | 10000 | Long
@@ -81,7 +81,7 @@ The component supports 88 options, which are listed below.
| *camel.component.salesforce.notify-for-operation-update* | Notify for update
operation, defaults to false (API version = 29.0) | | Boolean
| *camel.component.salesforce.notify-for-operations* | Notify for operations,
options are ALL, CREATE, EXTENDED, UPDATE (API version 29.0) | |
NotifyForOperationsEnum
| *camel.component.salesforce.object-mapper* | Custom Jackson ObjectMapper to
use when serializing/deserializing Salesforce objects. The option is a
com.fasterxml.jackson.databind.ObjectMapper type. | | ObjectMapper
-| *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.
| | String
+| *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. | | String
| *camel.component.salesforce.password* | Password used in OAuth flow to gain
access to access token. It's easy to get started with password OAuth flow, but
in general one should avoid it as it is deemed less secure than other flows.
Make sure that you append security token to the end of the password if using
one. | | String
| *camel.component.salesforce.pk-chunking* | Use PK Chunking. Only for use in
original Bulk API. Bulk 2.0 API performs PK chunking automatically, if
necessary. | | Boolean
| *camel.component.salesforce.pk-chunking-chunk-size* | Chunk size for use
with PK Chunking. If unspecified, salesforce default is 100,000. Maximum size
is 250,000. | | Integer
diff --git
a/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java
b/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java
index 4808bd3..246e33c 100644
---
a/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java
+++
b/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java
@@ -83,7 +83,8 @@ public class SalesforceComponentConfiguration
private Long defaultReplayId = -1L;
/**
* Payload format to use for Salesforce API calls, either JSON or XML,
- * defaults to JSON
+ * defaults to JSON. As of Camel 3.12, this option only applies to the Raw
+ * operation.
*/
private PayloadFormat format;
/**
@@ -176,10 +177,9 @@ public class SalesforceComponentConfiguration
private ObjectMapper objectMapper;
/**
* 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.
+ * 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.
*/
private String packages;
/**
diff --git a/docs/modules/ROOT/pages/huaweicloud-imagerecognition-starter.adoc
b/docs/modules/ROOT/pages/huaweicloud-imagerecognition-starter.adoc
index c86d072..2b4565d 100644
--- a/docs/modules/ROOT/pages/huaweicloud-imagerecognition-starter.adoc
+++ b/docs/modules/ROOT/pages/huaweicloud-imagerecognition-starter.adoc
@@ -24,10 +24,8 @@ The component supports 3 options, which are listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *camel.component.hwcloud-image.autowired-enabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | Boolean
-| *camel.component.hwcloud-image.enabled* | Whether to enable auto
configuration of the hwcloud-image component. This is enabled by default. | |
Boolean
-| *camel.component.hwcloud-image.lazy-start-producer* | 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 proces [...]
+| *camel.component.hwcloud-imagerecognition.autowired-enabled* | Whether
autowiring is enabled. This is used for automatic autowiring options (the
option must be marked as autowired) by looking up in the registry to find if
there is a single instance of matching type, which then gets configured on the
component. This can be used for automatic configuring JDBC data sources, JMS
connection factories, AWS Clients, etc. | true | Boolean
+| *camel.component.hwcloud-imagerecognition.enabled* | Whether to enable auto
configuration of the hwcloud-imagerecognition component. This is enabled by
default. | | Boolean
+| *camel.component.hwcloud-imagerecognition.lazy-start-producer* | 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 messag [...]
|===
-
-
// spring-boot-auto-configure options: END
diff --git a/docs/modules/ROOT/pages/kafka-starter.adoc
b/docs/modules/ROOT/pages/kafka-starter.adoc
index c8bd529..3e090c0 100644
--- a/docs/modules/ROOT/pages/kafka-starter.adoc
+++ b/docs/modules/ROOT/pages/kafka-starter.adoc
@@ -17,7 +17,7 @@ When using kafka with Spring Boot make sure to use the
following Maven dependenc
----
-The component supports 105 options, which are listed below.
+The component supports 104 options, which are listed below.
@@ -42,8 +42,7 @@ The component supports 105 options, which are listed below.
| *camel.component.kafka.configuration* | Allows to pre-configure the Kafka
component with common options that the endpoints will reuse. The option is a
org.apache.camel.component.kafka.KafkaConfiguration type. | |
KafkaConfiguration
| *camel.component.kafka.connection-max-idle-ms* | Close idle connections
after the number of milliseconds specified by this config. | 540000 | Integer
| *camel.component.kafka.consumer-request-timeout-ms* | The configuration
controls the maximum amount of time the client will wait for the response of a
request. If the response is not received before the timeout elapses the client
will resend the request if necessary or fail the request if retries are
exhausted. | 40000 | Integer
-| *camel.component.kafka.consumer-streams* | Number of concurrent consumers on
the consumer | 10 | Integer
-| *camel.component.kafka.consumers-count* | The number of consumers that
connect to kafka server | 1 | Integer
+| *camel.component.kafka.consumers-count* | The number of consumers that
connect to kafka server. Each consumer is run on a separate thread, that
retrieves and process the incoming data. | 1 | Integer
| *camel.component.kafka.delivery-timeout-ms* | An upper bound on the time to
report success or failure after a call to send() returns. This limits the total
time that a record will be delayed prior to sending, the time to await
acknowledgement from the broker (if expected), and the time allowed for
retriable send failures. | 120000 | Integer
| *camel.component.kafka.enable-idempotence* | If set to 'true' the producer
will ensure that exactly one copy of each message is written in the stream. If
'false', producer retries may write duplicates of the retried message in the
stream. If set to true this option will require
max.in.flight.requests.per.connection to be set to 1 and retries cannot be zero
and additionally acks must be set to 'all'. | false | Boolean
| *camel.component.kafka.enabled* | Whether to enable auto configuration of
the kafka component. This is enabled by default. | | Boolean
diff --git a/docs/modules/ROOT/pages/list.adoc
b/docs/modules/ROOT/pages/list.adoc
index b24e937..2afe35b 100644
--- a/docs/modules/ROOT/pages/list.adoc
+++ b/docs/modules/ROOT/pages/list.adoc
@@ -5,7 +5,7 @@ Apache Camel Spring Boot supports the following Camel artifacts
as Spring Boot S
== Camel Components
// components: START
-Number of Camel components: 338 in 274 JAR artifacts (1 deprecated)
+Number of Camel components: 339 in 274 JAR artifacts (1 deprecated)
[width="100%",cols="4,3,3,3,6",options="header"]
|===
@@ -293,6 +293,8 @@ Number of Camel components: 338 in 274 JAR artifacts (1
deprecated)
| xref:latest@components::http-component.adoc[HTTP] | camel-http-starter |
Stable | 2.3 | Send requests to external HTTP servers using Apache HTTP Client
4.x.
+| xref:latest@components::hwcloud-image-component.adoc[Huawei Cloud Image
Recognition] | camel-huaweicloud-imagerecognition-starter | Preview | 3.12 | To
identify objects, scenes, and concepts in images on Huawei Cloud
+
| xref:latest@components::hwcloud-imagerecognition-component.adoc[Huawei Cloud
Image Recognition] | camel-huaweicloud-imagerecognition-starter | Preview |
3.12 | To identify objects, scenes, and concepts in images on Huawei Cloud
| xref:latest@components::hwcloud-dms-component.adoc[Huawei Distributed
Message Service (DMS)] | camel-huaweicloud-dms-starter | Preview | 3.12 | To
integrate with a fully managed, high-performance message queuing service on
Huawei Cloud
diff --git a/docs/modules/ROOT/pages/salesforce-starter.adoc
b/docs/modules/ROOT/pages/salesforce-starter.adoc
index 48c201f..f48ab03 100644
--- a/docs/modules/ROOT/pages/salesforce-starter.adoc
+++ b/docs/modules/ROOT/pages/salesforce-starter.adoc
@@ -41,7 +41,7 @@ The component supports 88 options, which are listed below.
| *camel.component.salesforce.content-type* | Bulk API content type, one of
XML, CSV, ZIP_XML, ZIP_CSV | | ContentType
| *camel.component.salesforce.default-replay-id* | Default replayId setting if
no value is found in initialReplayIdMap | -1 | Long
| *camel.component.salesforce.enabled* | Whether to enable auto configuration
of the salesforce component. This is enabled by default. | | Boolean
-| *camel.component.salesforce.format* | Payload format to use for Salesforce
API calls, either JSON or XML, defaults to JSON | | PayloadFormat
+| *camel.component.salesforce.format* | Payload format to use for Salesforce
API calls, either JSON or XML, defaults to JSON. As of Camel 3.12, this option
only applies to the Raw operation. | | PayloadFormat
| *camel.component.salesforce.http-client* | Custom Jetty Http Client to use
to connect to Salesforce. The option is a
org.apache.camel.component.salesforce.SalesforceHttpClient type. | |
SalesforceHttpClient
| *camel.component.salesforce.http-client-connection-timeout* | Connection
timeout used by the HttpClient when connecting to the Salesforce server. |
60000 | Long
| *camel.component.salesforce.http-client-idle-timeout* | Timeout used by the
HttpClient when waiting for response from the Salesforce server. | 10000 | Long
@@ -81,7 +81,7 @@ The component supports 88 options, which are listed below.
| *camel.component.salesforce.notify-for-operation-update* | Notify for update
operation, defaults to false (API version = 29.0) | | Boolean
| *camel.component.salesforce.notify-for-operations* | Notify for operations,
options are ALL, CREATE, EXTENDED, UPDATE (API version 29.0) | |
NotifyForOperationsEnum
| *camel.component.salesforce.object-mapper* | Custom Jackson ObjectMapper to
use when serializing/deserializing Salesforce objects. The option is a
com.fasterxml.jackson.databind.ObjectMapper type. | | ObjectMapper
-| *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.
| | String
+| *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. | | String
| *camel.component.salesforce.password* | Password used in OAuth flow to gain
access to access token. It's easy to get started with password OAuth flow, but
in general one should avoid it as it is deemed less secure than other flows.
Make sure that you append security token to the end of the password if using
one. | | String
| *camel.component.salesforce.pk-chunking* | Use PK Chunking. Only for use in
original Bulk API. Bulk 2.0 API performs PK chunking automatically, if
necessary. | | Boolean
| *camel.component.salesforce.pk-chunking-chunk-size* | Chunk size for use
with PK Chunking. If unspecified, salesforce default is 100,000. Maximum size
is 250,000. | | Integer
