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.git
commit 8739513f0a2fd89c6540c938ba8148ab9cf675f9
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri May 7 15:39:29 2021 +0200
Regen
---
.../camel/catalog/components/vertx-kafka.json | 20 ++++-----
.../org/apache/camel/catalog/models.properties | 1 +
.../apache/camel/catalog/models/routeTemplate.json | 1 +
.../apache/camel/catalog/schemas/camel-spring.xsd | 27 ++++++++++++
.../dsl/yaml/deserializers/ModelDeserializers.java | 48 ++++++++++++++++++++++
.../deserializers/ModelDeserializersResolver.java | 2 +
.../src/generated/resources/camel-yaml-dsl.json | 16 ++++++++
7 files changed, 105 insertions(+), 10 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
index 4232783..41174b2 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
@@ -42,7 +42,7 @@
"requestTimeoutMs": { "kind": "property", "displayName": "Request Timeout
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "30s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client will wait [...]
"retryBackoffMs": { "kind": "property", "displayName": "Retry Backoff Ms",
"group": "common", "label": "common", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to retry a failed request to a [...]
"sendBufferBytes": { "kind": "property", "displayName": "Send Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 131072, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the [...]
- "socketConnectionSetupTimeoutMaxMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2m7s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clien [...]
+ "socketConnectionSetupTimeoutMaxMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the client [...]
"socketConnectionSetupTimeoutMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
client will wait for [...]
"allowAutoCreateTopics": { "kind": "property", "displayName": "Allow Auto
Create Topics", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Allow automatic topic
creation on the broker when subscrib [...]
"allowManualCommit": { "kind": "property", "displayName": "Allow Manual
Commit", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Whether to allow doing
manual commits via org.apache.camel.compone [...]
@@ -60,12 +60,12 @@
"groupId": { "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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique string that
identifies the consumer group this consumer belongs to. This property is
required [...]
"groupInstanceId": { "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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique identifier of
the consumer instance provided by the end user. Only non-empty [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "3s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator w [...]
- "isolationLevel": { "kind": "property", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Co [...]
+ "isolationLevel": { "kind": "property", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Co [...]
"keyDeserializer": { "kind": "property", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deserializ [...]
"maxPartitionFetchBytes": { "kind": "property", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "property", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer g [...]
- "maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()." },
- "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
+ "maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
+ "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
"seekToOffset": { "kind": "property", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take pr [...]
"seekToPosition": { "kind": "property", "displayName": "Seek To Position",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end on [...]
"sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group man [...]
@@ -94,7 +94,7 @@
"vertxKafkaClientFactory": { "kind": "property", "displayName": "Vertx
Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory", "deprecated":
false, "autowired": true, "secret": false, "description": "Factory to use for
creating io.vertx.kafka.client.consumer.KafkaConsumer and
io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to
configure a cust [...]
"vertxOptions": { "kind": "property", "displayName": "Vertx Options",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "io.vertx.core.VertxOptions", "deprecated": false, "autowired":
false, "secret": false, "description": "To provide a custom set of vertx
options for configuring vertx" },
"saslClientCallbackHandlerClass": { "kind": "property", "displayName":
"Sasl Client Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL client call [...]
- "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS co [...]
+ "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS co [...]
"saslKerberosKinitCmd": { "kind": "property", "displayName": "Sasl
Kerberos Kinit Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Kerberos kinit command
path." },
"saslKerberosMinTimeBeforeRelogin": { "kind": "property", "displayName":
"Sasl Kerberos Min Time Before Relogin", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread sleep time
betwe [...]
"saslKerberosServiceName": { "kind": "property", "displayName": "Sasl
Kerberos Service Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be d [...]
@@ -150,7 +150,7 @@
"requestTimeoutMs": { "kind": "parameter", "displayName": "Request Timeout
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "30s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client will wait [...]
"retryBackoffMs": { "kind": "parameter", "displayName": "Retry Backoff
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to retry a failed request to a [...]
"sendBufferBytes": { "kind": "parameter", "displayName": "Send Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 131072, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the [...]
- "socketConnectionSetupTimeoutMaxMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2m7s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clie [...]
+ "socketConnectionSetupTimeoutMaxMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clien [...]
"socketConnectionSetupTimeoutMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
client will wait for [...]
"allowAutoCreateTopics": { "kind": "parameter", "displayName": "Allow Auto
Create Topics", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Allow automatic topic
creation on the broker when subscri [...]
"allowManualCommit": { "kind": "parameter", "displayName": "Allow Manual
Commit", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Whether to allow doing
manual commits via org.apache.camel.compon [...]
@@ -168,12 +168,12 @@
"groupId": { "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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique string that
identifies the consumer group this consumer belongs to. This property is
require [...]
"groupInstanceId": { "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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique identifier of
the consumer instance provided by the end user. Only non-empt [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "3s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator [...]
- "isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "C [...]
+ "isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "C [...]
"keyDeserializer": { "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deseriali [...]
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer [...]
- "maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()." },
- "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
+ "maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
+ "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
"seekToOffset": { "kind": "parameter", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take p [...]
"seekToPosition": { "kind": "parameter", "displayName": "Seek To
Position", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end o [...]
"sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group ma [...]
@@ -199,7 +199,7 @@
"transactionTimeoutMs": { "kind": "parameter", "displayName": "Transaction
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time in ms that the transaction coordinat [...]
"valueSerializer": { "kind": "parameter", "displayName": "Value
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Serializer [...]
"saslClientCallbackHandlerClass": { "kind": "parameter", "displayName":
"Sasl Client Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL client cal [...]
- "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas
Config", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS c [...]
+ "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas
Config", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS c [...]
"saslKerberosKinitCmd": { "kind": "parameter", "displayName": "Sasl
Kerberos Kinit Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Kerberos kinit command
path." },
"saslKerberosMinTimeBeforeRelogin": { "kind": "parameter", "displayName":
"Sasl Kerberos Min Time Before Relogin", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread sleep time
betw [...]
"saslKerberosServiceName": { "kind": "parameter", "displayName": "Sasl
Kerberos Service Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models.properties
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models.properties
index a939487..d4c8669 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models.properties
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models.properties
@@ -182,6 +182,7 @@ stream-config
syslog
tarfile
template
+templateBean
templateParameter
threadPool
threadPoolProfile
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/routeTemplate.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/routeTemplate.json
index ea3c4c5..954b665 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/routeTemplate.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/routeTemplate.json
@@ -12,6 +12,7 @@
},
"properties": {
"templateParameter": { "kind": "element", "displayName": "Template
Parameter", "required": false, "type": "array", "javaType":
"java.util.List<org.apache.camel.model.RouteTemplateParameterDefinition>",
"deprecated": false, "autowired": false, "secret": false, "description": "Adds
a parameter the route template uses." },
+ "templateBean": { "kind": "element", "displayName": "Template Bean",
"required": false, "type": "array", "javaType":
"java.util.List<org.apache.camel.model.RouteTemplateBeanDefinition>",
"deprecated": false, "autowired": false, "secret": false, "description": "Adds
a local bean the route template uses." },
"route": { "kind": "element", "displayName": "Route", "required": true,
"type": "object", "javaType": "org.apache.camel.model.RouteDefinition",
"deprecated": false, "autowired": false, "secret": false, "description": "To
define the route in the template" },
"id": { "kind": "attribute", "displayName": "Id", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Sets the id of this node"
},
"description": { "kind": "element", "displayName": "Description",
"required": false, "type": "object", "javaType":
"org.apache.camel.model.DescriptionDefinition", "deprecated": false,
"autowired": false, "secret": false, "description": "Sets the description of
this node" }
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
index 1799b69..9f164aa 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
@@ -1584,6 +1584,14 @@ Configures a ProducerTemplate
</xs:annotation>
</xs:element>
+ <xs:element name="templateBean" type="tns:routeTemplateBeanDefinition">
+ <xs:annotation>
+ <xs:documentation xml:lang="en"><![CDATA[
+A route template bean (local bean)
+ ]]></xs:documentation>
+ </xs:annotation>
+ </xs:element>
+
<xs:element name="templateParameter"
type="tns:routeTemplateParameterDefinition">
<xs:annotation>
<xs:documentation xml:lang="en"><![CDATA[
@@ -10280,6 +10288,24 @@ Whether tracing is enabled on this route.
</xs:complexContent>
</xs:complexType>
+ <xs:complexType name="routeTemplateBeanDefinition">
+ <xs:sequence/>
+ <xs:attribute name="name" type="xs:string" use="required">
+ <xs:annotation>
+ <xs:documentation xml:lang="en"><![CDATA[
+Bean name.
+ ]]></xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+ <xs:attribute name="beanType" type="xs:string">
+ <xs:annotation>
+ <xs:documentation xml:lang="en"><![CDATA[
+Sets the Class of the bean.
+ ]]></xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+ </xs:complexType>
+
<xs:complexType name="routeTemplateContextRefDefinition">
<xs:sequence/>
<xs:attribute name="ref" type="xs:string" use="required">
@@ -10296,6 +10322,7 @@ Reference to the route templates in the xml dsl.
<xs:extension base="tns:optionalIdentifiedDefinition">
<xs:sequence>
<xs:element maxOccurs="unbounded" minOccurs="0"
ref="tns:templateParameter"/>
+ <xs:element maxOccurs="unbounded" minOccurs="0"
ref="tns:templateBean"/>
<xs:element ref="tns:route"/>
</xs:sequence>
</xs:extension>
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
index af51472..dfc0d35 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
@@ -71,6 +71,7 @@ import org.apache.camel.model.RollbackDefinition;
import org.apache.camel.model.RouteBuilderDefinition;
import org.apache.camel.model.RouteContextRefDefinition;
import org.apache.camel.model.RouteDefinition;
+import org.apache.camel.model.RouteTemplateBeanDefinition;
import org.apache.camel.model.RouteTemplateParameterDefinition;
import org.apache.camel.model.RoutingSlipDefinition;
import org.apache.camel.model.SagaActionUriDefinition;
@@ -11733,6 +11734,53 @@ public final class ModelDeserializers extends
YamlDeserializerSupport {
}
@YamlType(
+ inline = true,
+ types = org.apache.camel.model.RouteTemplateBeanDefinition.class,
+ order =
org.apache.camel.dsl.yaml.common.YamlDeserializerResolver.ORDER_LOWEST - 1,
+ nodes = "template-bean",
+ properties = {
+ @YamlProperty(name = "bean-type", type = "string"),
+ @YamlProperty(name = "name", type = "string", required =
true)
+ }
+ )
+ public static class RouteTemplateBeanDefinitionDeserializer extends
YamlDeserializerBase<RouteTemplateBeanDefinition> {
+ public RouteTemplateBeanDefinitionDeserializer() {
+ super(RouteTemplateBeanDefinition.class);
+ }
+
+ @Override
+ protected RouteTemplateBeanDefinition newInstance() {
+ return new RouteTemplateBeanDefinition();
+ }
+
+ @Override
+ protected RouteTemplateBeanDefinition newInstance(String value) {
+ return new RouteTemplateBeanDefinition(value);
+ }
+
+ @Override
+ protected boolean setProperty(RouteTemplateBeanDefinition target,
String propertyKey,
+ String propertyName, Node node) {
+ switch(propertyKey) {
+ case "bean-type": {
+ String val = asText(node);
+ target.setBeanType(val);
+ break;
+ }
+ case "name": {
+ String val = asText(node);
+ target.setName(val);
+ break;
+ }
+ default: {
+ return false;
+ }
+ }
+ return true;
+ }
+ }
+
+ @YamlType(
types =
org.apache.camel.model.RouteTemplateParameterDefinition.class,
order =
org.apache.camel.dsl.yaml.common.YamlDeserializerResolver.ORDER_LOWEST - 1,
nodes = "template-parameter",
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializersResolver.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializersResolver.java
index b13243e..10d3065 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializersResolver.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializersResolver.java
@@ -292,6 +292,8 @@ public final class ModelDeserializersResolver implements
YamlDeserializerResolve
case "org.apache.camel.model.RouteContextRefDefinition": return
new ModelDeserializers.RouteContextRefDefinitionDeserializer();
case "route": return new
ModelDeserializers.RouteDefinitionDeserializer();
case "org.apache.camel.model.RouteDefinition": return new
ModelDeserializers.RouteDefinitionDeserializer();
+ case "template-bean": return new
ModelDeserializers.RouteTemplateBeanDefinitionDeserializer();
+ case "org.apache.camel.model.RouteTemplateBeanDefinition": return
new ModelDeserializers.RouteTemplateBeanDefinitionDeserializer();
case "template-parameter": return new
ModelDeserializers.RouteTemplateParameterDefinitionDeserializer();
case "org.apache.camel.model.RouteTemplateParameterDefinition":
return new ModelDeserializers.RouteTemplateParameterDefinitionDeserializer();
case "routing-slip": return new
ModelDeserializers.RoutingSlipDefinitionDeserializer();
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camel-yaml-dsl.json
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camel-yaml-dsl.json
index d2f441c..01d7acd 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camel-yaml-dsl.json
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camel-yaml-dsl.json
@@ -2059,6 +2059,22 @@
},
"required" : [ "from", "steps" ]
},
+ "org.apache.camel.model.RouteTemplateBeanDefinition" : {
+ "oneOf" : [ {
+ "type" : "string"
+ }, {
+ "type" : "object",
+ "properties" : {
+ "bean-type" : {
+ "type" : "string"
+ },
+ "name" : {
+ "type" : "string"
+ }
+ }
+ } ],
+ "required" : [ "name" ]
+ },
"org.apache.camel.model.RouteTemplateDefinition" : {
"type" : "object",
"properties" : {
