This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 01b4d9c0a1b [create-pull-request] automated change (#1693)
01b4d9c0a1b is described below
commit 01b4d9c0a1b26b099d691863683d0c6893f6fe2d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Mar 3 07:13:46 2026 +0100
[create-pull-request] automated change (#1693)
Co-authored-by: oscerd <[email protected]>
---
.../springboot/catalog/components/huggingface.json | 42 +++++++++++-----------
.../camel/springboot/catalog/components/kafka.json | 4 +--
.../src/main/docs/huggingface.json | 7 ++++
.../HuggingFaceComponentConfiguration.java | 13 +++++++
.../camel-kafka-starter/src/main/docs/kafka.json | 2 +-
.../springboot/KafkaComponentConfiguration.java | 5 ++-
6 files changed, 49 insertions(+), 24 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/huggingface.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/huggingface.json
index b72e084edf3..3facf96484b 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/huggingface.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/huggingface.json
@@ -35,17 +35,18 @@
"modelId": { "index": 8, "kind": "property", "displayName": "Model Id",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Hugging Face model ID
(e.g., distilbert-base-uncased-finetuned-sst-2-english)" },
"modelLoadingTimeout": { "index": 9, "kind": "property", "displayName":
"Model Loading Timeout", "group": "producer", "label": "", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Model loading timeout in
seconds, if negative then use default (240 seconds)" },
"multiLabel": { "index": 10, "kind": "property", "displayName": "Multi
Label", "group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Allow multi-label
classifications for zero-shot tasks" },
- "predictorBean": { "index": 11, "kind": "property", "displayName":
"Predictor Bean", "group": "producer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Bean name of a custom
TaskPredictor implementation (for tasks not covered b [...]
- "predictTimeout": { "index": 12, "kind": "property", "displayName":
"Predict Timeout", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Predict timeout in
seconds, if negative then use default (120 seconds)" },
- "revision": { "index": 13, "kind": "property", "displayName": "Revision",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Model revision or branch
(default: main)" },
- "systemPrompt": { "index": 14, "kind": "property", "displayName": "System
Prompt", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Initial system prompt
for chat tasks (e.g., 'You are a helpful assistant name [...]
- "temperature": { "index": 15, "kind": "property", "displayName":
"Temperature", "group": "producer", "label": "", "required": false, "type":
"number", "javaType": "float", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Temperature for sampling
(0.0-1.0)" },
- "topK": { "index": 16, "kind": "property", "displayName": "Top K",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 5, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Top-k parameter for
classification tasks" },
- "userRole": { "index": 17, "kind": "property", "displayName": "User Role",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "user", "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Role for user messages
in chat history (e.g., 'user' or 'human')" },
- "autowiredEnabled": { "index": 18, "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 [...]
- "healthCheckConsumerEnabled": { "index": 19, "kind": "property",
"displayName": "Health Check Consumer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all consumer based health checks
from this component" },
- "healthCheckProducerEnabled": { "index": 20, "kind": "property",
"displayName": "Health Check Producer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all producer based health checks
from this component. Notice: Camel has by default disabled all producer based
health-checks. You can turn on produce [...]
- "oauthProfile": { "index": 21, "kind": "property", "displayName": "Oauth
Profile", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "OAuth profile name for
obtaining an access token via the OAuth 2.0 Cl [...]
+ "pooling": { "index": 11, "kind": "property", "displayName": "Pooling",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Whether to pool the
predictor (keep the Python process alive) or create a new one for each request"
},
+ "predictorBean": { "index": 12, "kind": "property", "displayName":
"Predictor Bean", "group": "producer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Bean name of a custom
TaskPredictor implementation (for tasks not covered b [...]
+ "predictTimeout": { "index": 13, "kind": "property", "displayName":
"Predict Timeout", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Predict timeout in
seconds, if negative then use default (120 seconds)" },
+ "revision": { "index": 14, "kind": "property", "displayName": "Revision",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Model revision or branch
(default: main)" },
+ "systemPrompt": { "index": 15, "kind": "property", "displayName": "System
Prompt", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Initial system prompt
for chat tasks (e.g., 'You are a helpful assistant name [...]
+ "temperature": { "index": 16, "kind": "property", "displayName":
"Temperature", "group": "producer", "label": "", "required": false, "type":
"number", "javaType": "float", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Temperature for sampling
(0.0-1.0)" },
+ "topK": { "index": 17, "kind": "property", "displayName": "Top K",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 5, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Top-k parameter for
classification tasks" },
+ "userRole": { "index": 18, "kind": "property", "displayName": "User Role",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "user", "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Role for user messages
in chat history (e.g., 'user' or 'human')" },
+ "autowiredEnabled": { "index": 19, "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 [...]
+ "healthCheckConsumerEnabled": { "index": 20, "kind": "property",
"displayName": "Health Check Consumer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all consumer based health checks
from this component" },
+ "healthCheckProducerEnabled": { "index": 21, "kind": "property",
"displayName": "Health Check Producer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all producer based health checks
from this component. Notice: Camel has by default disabled all producer based
health-checks. You can turn on produce [...]
+ "oauthProfile": { "index": 22, "kind": "property", "displayName": "Oauth
Profile", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "OAuth profile name for
obtaining an access token via the OAuth 2.0 Cl [...]
},
"headers": {
"CamelHuggingFaceOutput": { "index": 0, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The output from the model", "constantName":
"org.apache.camel.component.huggingface.HuggingFaceConstants#OUTPUT" }
@@ -61,14 +62,15 @@
"modelId": { "index": 7, "kind": "parameter", "displayName": "Model Id",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Hugging Face model ID
(e.g., distilbert-base-uncased-finetuned-sst-2-english)" },
"modelLoadingTimeout": { "index": 8, "kind": "parameter", "displayName":
"Model Loading Timeout", "group": "producer", "label": "", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Model loading timeout in
seconds, if negative then use default (240 seconds)" },
"multiLabel": { "index": 9, "kind": "parameter", "displayName": "Multi
Label", "group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Allow multi-label
classifications for zero-shot tasks" },
- "predictorBean": { "index": 10, "kind": "parameter", "displayName":
"Predictor Bean", "group": "producer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Bean name of a custom
TaskPredictor implementation (for tasks not covered [...]
- "predictTimeout": { "index": 11, "kind": "parameter", "displayName":
"Predict Timeout", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Predict timeout in
seconds, if negative then use default (120 seconds)" },
- "revision": { "index": 12, "kind": "parameter", "displayName": "Revision",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Model revision or branch
(default: main)" },
- "systemPrompt": { "index": 13, "kind": "parameter", "displayName": "System
Prompt", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Initial system prompt
for chat tasks (e.g., 'You are a helpful assistant nam [...]
- "temperature": { "index": 14, "kind": "parameter", "displayName":
"Temperature", "group": "producer", "label": "", "required": false, "type":
"number", "javaType": "float", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Temperature for sampling
(0.0-1.0)" },
- "topK": { "index": 15, "kind": "parameter", "displayName": "Top K",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 5, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Top-k parameter for
classification tasks" },
- "userRole": { "index": 16, "kind": "parameter", "displayName": "User
Role", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "user", "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Role for user messages
in chat history (e.g., 'user' or 'human')" },
- "lazyStartProducer": { "index": 17, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "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 produ [...]
- "oauthProfile": { "index": 18, "kind": "parameter", "displayName": "Oauth
Profile", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "OAuth profile name for
obtaining an access token via the OAuth 2.0 C [...]
+ "pooling": { "index": 10, "kind": "parameter", "displayName": "Pooling",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Whether to pool the
predictor (keep the Python process alive) or create a new one for each request"
},
+ "predictorBean": { "index": 11, "kind": "parameter", "displayName":
"Predictor Bean", "group": "producer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Bean name of a custom
TaskPredictor implementation (for tasks not covered [...]
+ "predictTimeout": { "index": 12, "kind": "parameter", "displayName":
"Predict Timeout", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Predict timeout in
seconds, if negative then use default (120 seconds)" },
+ "revision": { "index": 13, "kind": "parameter", "displayName": "Revision",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Model revision or branch
(default: main)" },
+ "systemPrompt": { "index": 14, "kind": "parameter", "displayName": "System
Prompt", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Initial system prompt
for chat tasks (e.g., 'You are a helpful assistant nam [...]
+ "temperature": { "index": 15, "kind": "parameter", "displayName":
"Temperature", "group": "producer", "label": "", "required": false, "type":
"number", "javaType": "float", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Temperature for sampling
(0.0-1.0)" },
+ "topK": { "index": 16, "kind": "parameter", "displayName": "Top K",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 5, "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Top-k parameter for
classification tasks" },
+ "userRole": { "index": 17, "kind": "parameter", "displayName": "User
Role", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "user", "configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "Role for user messages
in chat history (e.g., 'user' or 'human')" },
+ "lazyStartProducer": { "index": 18, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "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 produ [...]
+ "oauthProfile": { "index": 19, "kind": "parameter", "displayName": "Oauth
Profile", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.huggingface.HuggingFaceConfiguration",
"configurationField": "configuration", "description": "OAuth profile name for
obtaining an access token via the OAuth 2.0 C [...]
}
}
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 27f1bbab405..3c26c3360a8 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
@@ -50,7 +50,7 @@
"fetchWaitMaxMs": { "index": 23, "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 [...]
"groupId": { "index": 24, "kind": "property", "displayName": "Group Id",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A string that uniquely identifies the group of
consumer processes to which this consumer belongs. By setting the s [...]
"groupInstanceId": { "index": 25, "kind": "property", "displayName":
"Group Instance Id", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are [...]
- "groupProtocol": { "index": 26, "kind": "property", "displayName": "Group
Protocol", "group": "consumer", "label": "consumer", "required": false, "type":
"enum", "javaType": "java.lang.String", "enum": [ "classic", "consumer" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"classic", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The consumer group protocol to use. The cl
[...]
+ "groupProtocol": { "index": 26, "kind": "property", "displayName": "Group
Protocol", "group": "consumer", "label": "consumer", "required": false, "type":
"enum", "javaType": "java.lang.String", "enum": [ "classic", "consumer" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"classic", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The consumer group protocol to use. The cl
[...]
"groupRemoteAssignor": { "index": 27, "kind": "property", "displayName":
"Group Remote Assignor", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the server-side assignor to use
when group.protocol is set to consumer. If no [...]
"headerDeserializer": { "index": 28, "kind": "property", "displayName":
"Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to des
[...]
"heartbeatIntervalMs": { "index": 29, "kind": "property", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 3000,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator [...]
@@ -195,7 +195,7 @@
"fetchWaitMaxMs": { "index": 22, "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 fetc [...]
"groupId": { "index": 23, "kind": "parameter", "displayName": "Group Id",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A string that uniquely identifies the group of
consumer processes to which this consumer belongs. By setting the [...]
"groupInstanceId": { "index": 24, "kind": "parameter", "displayName":
"Group Instance Id", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A unique identifier of the consumer instance
provided by the end user. Only non-empty strings ar [...]
- "groupProtocol": { "index": 25, "kind": "parameter", "displayName": "Group
Protocol", "group": "consumer", "label": "consumer", "required": false, "type":
"enum", "javaType": "java.lang.String", "enum": [ "classic", "consumer" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"classic", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The consumer group protocol to use. The c [...]
+ "groupProtocol": { "index": 25, "kind": "parameter", "displayName": "Group
Protocol", "group": "consumer", "label": "consumer", "required": false, "type":
"enum", "javaType": "java.lang.String", "enum": [ "classic", "consumer" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"classic", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The consumer group protocol to use. The c [...]
"groupRemoteAssignor": { "index": 26, "kind": "parameter", "displayName":
"Group Remote Assignor", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the server-side assignor to use
when group.protocol is set to consumer. If n [...]
"headerDeserializer": { "index": 27, "kind": "parameter", "displayName":
"Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to de
[...]
"heartbeatIntervalMs": { "index": 28, "kind": "parameter", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 3000,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator [...]
diff --git
a/components-starter/camel-huggingface-starter/src/main/docs/huggingface.json
b/components-starter/camel-huggingface-starter/src/main/docs/huggingface.json
index ef5675080c4..b3a1e2e50b4 100644
---
a/components-starter/camel-huggingface-starter/src/main/docs/huggingface.json
+++
b/components-starter/camel-huggingface-starter/src/main/docs/huggingface.json
@@ -121,6 +121,13 @@
"description": "OAuth profile name for obtaining an access token via the
OAuth 2.0 Client Credentials grant. When set, the token is acquired from the
configured identity provider and used as authToken. Requires camel-oauth on the
classpath.",
"sourceType":
"org.apache.camel.component.huggingface.springboot.HuggingFaceComponentConfiguration"
},
+ {
+ "name": "camel.component.huggingface.pooling",
+ "type": "java.lang.Boolean",
+ "description": "Whether to pool the predictor (keep the Python process
alive) or create a new one for each request",
+ "sourceType":
"org.apache.camel.component.huggingface.springboot.HuggingFaceComponentConfiguration",
+ "defaultValue": true
+ },
{
"name": "camel.component.huggingface.predict-timeout",
"type": "java.lang.Integer",
diff --git
a/components-starter/camel-huggingface-starter/src/main/java/org/apache/camel/component/huggingface/springboot/HuggingFaceComponentConfiguration.java
b/components-starter/camel-huggingface-starter/src/main/java/org/apache/camel/component/huggingface/springboot/HuggingFaceComponentConfiguration.java
index a722742046b..a69da141648 100644
---
a/components-starter/camel-huggingface-starter/src/main/java/org/apache/camel/component/huggingface/springboot/HuggingFaceComponentConfiguration.java
+++
b/components-starter/camel-huggingface-starter/src/main/java/org/apache/camel/component/huggingface/springboot/HuggingFaceComponentConfiguration.java
@@ -91,6 +91,11 @@ public class HuggingFaceComponentConfiguration
* Allow multi-label classifications for zero-shot tasks
*/
private Boolean multiLabel = false;
+ /**
+ * Whether to pool the predictor (keep the Python process alive) or create
a
+ * new one for each request
+ */
+ private Boolean pooling = true;
/**
* Bean name of a custom TaskPredictor implementation (for tasks not
covered
* by built-in predictors)
@@ -238,6 +243,14 @@ public class HuggingFaceComponentConfiguration
this.multiLabel = multiLabel;
}
+ public Boolean getPooling() {
+ return pooling;
+ }
+
+ public void setPooling(Boolean pooling) {
+ this.pooling = pooling;
+ }
+
public String getPredictorBean() {
return predictorBean;
}
diff --git a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
index df0a4bff699..66f1817db87 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
@@ -229,7 +229,7 @@
{
"name": "camel.component.kafka.group-protocol",
"type": "java.lang.String",
- "description": "The consumer group protocol to use. The classic protocol
uses the traditional partition assignment and rebalancing mechanism. The
consumer protocol enables the new KIP-848 consumer rebalance protocol which
provides faster and more efficient rebalancing.",
+ "description": "The consumer group protocol to use. The classic protocol
uses the traditional partition assignment and rebalancing mechanism. The
consumer protocol enables the new KIP-848 consumer rebalance protocol which
provides faster and more efficient rebalancing. When set to consumer,
classic-only properties (heartbeatIntervalMs, sessionTimeoutMs,
partitionAssignor) are automatically excluded from the consumer configuration.",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": "classic"
},
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 1d3a22272a5..a5b38f3d189 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
@@ -256,7 +256,10 @@ public class KafkaComponentConfiguration
* The consumer group protocol to use. The classic protocol uses the
* traditional partition assignment and rebalancing mechanism. The consumer
* protocol enables the new KIP-848 consumer rebalance protocol which
- * provides faster and more efficient rebalancing.
+ * provides faster and more efficient rebalancing. When set to consumer,
+ * classic-only properties (heartbeatIntervalMs, sessionTimeoutMs,
+ * partitionAssignor) are automatically excluded from the consumer
+ * configuration.
*/
private String groupProtocol = "classic";
/**
