This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/master by this push:
new a7be470 Regen
a7be470 is described below
commit a7be470fe657dbb9e471f29b81d2e11399d37319
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Jan 11 18:14:22 2021 +0100
Regen
---
.../springboot/catalog/components/vertx-kafka.json | 34 ++++---
components-starter/camel-corda-starter/pom.xml | 8 ++
components-starter/camel-iota-starter/pom.xml | 12 +++
.../src/main/docs/vertx-kafka-starter.adoc | 17 ++--
.../VertxKafkaComponentConfiguration.java | 106 ++++++++++++++++++---
docs/modules/ROOT/pages/vertx-kafka-starter.adoc | 17 ++--
tooling/camel-spring-boot-dependencies/pom.xml | 2 +-
7 files changed, 160 insertions(+), 36 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
index eea01df..bddb59a 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
@@ -33,7 +33,7 @@
"metadataMaxAgeMs": { "kind": "property", "displayName": "Metadata Max Age
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The period of time in
milliseconds after which we force a refresh of metad [...]
"metricReporters": { "kind": "property", "displayName": "Metric
Reporters", "group": "common", "label": "common", "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 list of classes to use
as metrics reporters. Implementing the org.apache.kafka.common.me [...]
"metricsNumSamples": { "kind": "property", "displayName": "Metrics Num
Samples", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of samples
maintained to compute metrics." },
- "metricsRecordingLevel": { "kind": "property", "displayName": "Metrics
Recording Level", "group": "common", "label": "common", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "INFO", "DEBUG" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"INFO", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The highest recording le
[...]
+ "metricsRecordingLevel": { "kind": "property", "displayName": "Metrics
Recording Level", "group": "common", "label": "common", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "INFO", "DEBUG",
"TRACE" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "INFO", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The highest rec [...]
"metricsSampleWindowMs": { "kind": "property", "displayName": "Metrics
Sample Window 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 window of time a
metrics sample is computed over." },
"partitionId": { "kind": "property", "displayName": "Partition Id",
"group": "common", "label": "common", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The partition to which
the record will be sent (or null if no partition was specified) or read f [...]
"receiveBufferBytes": { "kind": "property", "displayName": "Receive Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 32768, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP
receive buffer (SO_RCVBUF) to use when reading data. [...]
@@ -42,6 +42,8 @@
"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 [...]
+ "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 [...]
"autoCommitIntervalMs": { "kind": "property", "displayName": "Auto Commit
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The frequency in
milliseconds that the consumer offsets are aut [...]
"autoOffsetReset": { "kind": "property", "displayName": "Auto Offset
Reset", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "latest", "earliest",
"none" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "latest", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "What to do when t [...]
@@ -76,14 +78,14 @@
"keySerializer": { "kind": "property", "displayName": "Key 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 class [...]
"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 [...]
"lingerMs": { "kind": "property", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer groups
together any records that arrive in between request transmissions i [...]
- "maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls how long KafkaProducer.send() and KafkaProducer.partitio [...]
+ "maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls how long the KafkaProducer's send(), partitionsFor(), in [...]
"maxInFlightRequestsPerConnection": { "kind": "property", "displayName":
"Max In Flight Requests Per Connection", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
unacknowledged requ [...]
"maxRequestSize": { "kind": "property", "displayName": "Max Request Size",
"group": "producer", "label": "producer", "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 size of a
request in bytes. This setting will limit the number [...]
"metadataMaxIdleMs": { "kind": "property", "displayName": "Metadata Max
Idle Ms", "group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Controls how long the
producer will cache metadata for a topic that' [...]
"partitionerClass": { "kind": "property", "displayName": "Partitioner
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Pa [...]
"retries": { "kind": "property", "displayName": "Retries", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Setting a value greater
than zero will cause the client to resend any record whose send [...]
"transactionalId": { "kind": "property", "displayName": "Transactional
Id", "group": "producer", "label": "producer", "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 TransactionalId to
use for transactional delivery. This enables reliability semant [...]
- "transactionTimeoutMs": { "kind": "property", "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 coordinato [...]
+ "transactionTimeoutMs": { "kind": "property", "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 coordinato [...]
"valueSerializer": { "kind": "property", "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 c [...]
"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 [...]
"vertx": { "kind": "property", "displayName": "Vertx", "group":
"advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "io.vertx.core.Vertx", "deprecated": false, "autowired": true,
"secret": false, "description": "To use an existing vertx instead of creating a
new instance" },
@@ -109,16 +111,19 @@
"sslEndpointIdentificationAlgorithm": { "kind": "property", "displayName":
"Ssl Endpoint Identification Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "https", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The endpoint i [...]
"sslEngineFactoryClass": { "kind": "property", "displayName": "Ssl Engine
Factory 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 class of type
org.apache.kafka.common.security.auth.SslEngine [...]
"sslKeymanagerAlgorithm": { "kind": "property", "displayName": "Ssl
Keymanager Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"SunX509", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The algorithm used by
key manager fac [...]
- "sslKeyPassword": { "kind": "property", "displayName": "Ssl Key Password",
"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 password of the
private key in the key store file. This is optional for client." },
+ "sslKeyPassword": { "kind": "property", "displayName": "Ssl Key Password",
"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 password of the
private key in the key store file orthe PEM key specified in [...]
+ "sslKeystoreCertificateChain": { "kind": "property", "displayName": "Ssl
Keystore Certificate Chain", "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": "Certificate chain in the
format specified by 'ssl.key [...]
+ "sslKeystoreKey": { "kind": "property", "displayName": "Ssl Keystore Key",
"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": "Private key in the
format specified by 'ssl.keystore.type'. Default SSL engine f [...]
"sslKeystoreLocation": { "kind": "property", "displayName": "Ssl Keystore
Location", "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 location of the key
store file. This is optional for client and ca [...]
- "sslKeystorePassword": { "kind": "property", "displayName": "Ssl Keystore
Password", "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 store password for
the key store file. This is optional for client [...]
+ "sslKeystorePassword": { "kind": "property", "displayName": "Ssl Keystore
Password", "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 store password for
the key store file. This is optional for client [...]
"sslKeystoreType": { "kind": "property", "displayName": "Ssl Keystore
Type", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional [...]
"sslProtocol": { "kind": "property", "displayName": "Ssl Protocol",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "TLSv1.2", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The SSL protocol used to
generate the SSLContext. The defaul [...]
"sslProvider": { "kind": "property", "displayName": "Ssl Provider",
"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 name of the security
provider used for SSL connections. Default value is the defaul [...]
"sslSecureRandomImplementation": { "kind": "property", "displayName": "Ssl
Secure Random Implementation", "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 SecureRandom PRNG
implementation to use for S [...]
"sslTrustmanagerAlgorithm": { "kind": "property", "displayName": "Ssl
Trustmanager Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PKIX", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The algorithm used by
trust manager [...]
+ "sslTruststoreCertificates": { "kind": "property", "displayName": "Ssl
Truststore Certificates", "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": "Trusted certificates in
the format specified by 'ssl.trust [...]
"sslTruststoreLocation": { "kind": "property", "displayName": "Ssl
Truststore Location", "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 location of the
trust store file." },
- "sslTruststorePassword": { "kind": "property", "displayName": "Ssl
Truststore Password", "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 password for the
trust store file. If a password is not set ac [...]
+ "sslTruststorePassword": { "kind": "property", "displayName": "Ssl
Truststore Password", "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 password for the
trust store file. If a password is not set, t [...]
"sslTruststoreType": { "kind": "property", "displayName": "Ssl Truststore
Type", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
trust store file." }
},
"properties": {
@@ -133,7 +138,7 @@
"metadataMaxAgeMs": { "kind": "parameter", "displayName": "Metadata Max
Age Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The period of time in
milliseconds after which we force a refresh of meta [...]
"metricReporters": { "kind": "parameter", "displayName": "Metric
Reporters", "group": "common", "label": "common", "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 list of classes to use
as metrics reporters. Implementing the org.apache.kafka.common.m [...]
"metricsNumSamples": { "kind": "parameter", "displayName": "Metrics Num
Samples", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of samples
maintained to compute metrics." },
- "metricsRecordingLevel": { "kind": "parameter", "displayName": "Metrics
Recording Level", "group": "common", "label": "common", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "INFO", "DEBUG" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"INFO", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The highest recording l
[...]
+ "metricsRecordingLevel": { "kind": "parameter", "displayName": "Metrics
Recording Level", "group": "common", "label": "common", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "INFO", "DEBUG",
"TRACE" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "INFO", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The highest re [...]
"metricsSampleWindowMs": { "kind": "parameter", "displayName": "Metrics
Sample Window 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 window of time a
metrics sample is computed over." },
"partitionId": { "kind": "parameter", "displayName": "Partition Id",
"group": "common", "label": "common", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The partition to which
the record will be sent (or null if no partition was specified) or read [...]
"receiveBufferBytes": { "kind": "parameter", "displayName": "Receive
Buffer Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 32768, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP
receive buffer (SO_RCVBUF) to use when reading data [...]
@@ -142,6 +147,8 @@
"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 [...]
+ "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 [...]
"autoCommitIntervalMs": { "kind": "parameter", "displayName": "Auto Commit
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The frequency in
milliseconds that the consumer offsets are au [...]
"autoOffsetReset": { "kind": "parameter", "displayName": "Auto Offset
Reset", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "latest", "earliest",
"none" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "latest", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "What to do when [...]
@@ -178,14 +185,14 @@
"keySerializer": { "kind": "parameter", "displayName": "Key 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 clas [...]
"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 [...]
"lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer groups
together any records that arrive in between request transmissions [...]
- "maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls how long KafkaProducer.send() and KafkaProducer.partiti [...]
+ "maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls how long the KafkaProducer's send(), partitionsFor(), i [...]
"maxInFlightRequestsPerConnection": { "kind": "parameter", "displayName":
"Max In Flight Requests Per Connection", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
unacknowledged req [...]
"maxRequestSize": { "kind": "parameter", "displayName": "Max Request
Size", "group": "producer", "label": "producer", "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 size of a
request in bytes. This setting will limit the numbe [...]
"metadataMaxIdleMs": { "kind": "parameter", "displayName": "Metadata Max
Idle Ms", "group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Controls how long the
producer will cache metadata for a topic that [...]
"partitionerClass": { "kind": "parameter", "displayName": "Partitioner
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "P [...]
"retries": { "kind": "parameter", "displayName": "Retries", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Setting a value greater
than zero will cause the client to resend any record whose sen [...]
"transactionalId": { "kind": "parameter", "displayName": "Transactional
Id", "group": "producer", "label": "producer", "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 TransactionalId to
use for transactional delivery. This enables reliability seman [...]
- "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 [...]
+ "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 [...]
"synchronous": { "kind": "parameter", "displayName": "Synchronous",
"group": "advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Sets whether synchronous
processing should be strictly used, or Camel is allowed to use asynchronous
processing (if supported)." },
"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 [...]
@@ -209,16 +216,19 @@
"sslEndpointIdentificationAlgorithm": { "kind": "parameter",
"displayName": "Ssl Endpoint Identification Algorithm", "group": "security",
"label": "common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "https", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The endpoint [...]
"sslEngineFactoryClass": { "kind": "parameter", "displayName": "Ssl Engine
Factory 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 class of type
org.apache.kafka.common.security.auth.SslEngin [...]
"sslKeymanagerAlgorithm": { "kind": "parameter", "displayName": "Ssl
Keymanager Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"SunX509", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The algorithm used by
key manager fa [...]
- "sslKeyPassword": { "kind": "parameter", "displayName": "Ssl Key
Password", "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 password of the
private key in the key store file. This is optional for cli [...]
+ "sslKeyPassword": { "kind": "parameter", "displayName": "Ssl Key
Password", "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 password of the
private key in the key store file orthe PEM key specified i [...]
+ "sslKeystoreCertificateChain": { "kind": "parameter", "displayName": "Ssl
Keystore Certificate Chain", "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": "Certificate chain in the
format specified by 'ssl.ke [...]
+ "sslKeystoreKey": { "kind": "parameter", "displayName": "Ssl Keystore
Key", "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": "Private key in the
format specified by 'ssl.keystore.type'. Default SSL engine [...]
"sslKeystoreLocation": { "kind": "parameter", "displayName": "Ssl Keystore
Location", "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 location of the key
store file. This is optional for client and c [...]
- "sslKeystorePassword": { "kind": "parameter", "displayName": "Ssl Keystore
Password", "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 store password for
the key store file. This is optional for clien [...]
+ "sslKeystorePassword": { "kind": "parameter", "displayName": "Ssl Keystore
Password", "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 store password for
the key store file. This is optional for clien [...]
"sslKeystoreType": { "kind": "parameter", "displayName": "Ssl Keystore
Type", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optiona [...]
"sslProtocol": { "kind": "parameter", "displayName": "Ssl Protocol",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "TLSv1.2", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The SSL protocol used to
generate the SSLContext. The defau [...]
"sslProvider": { "kind": "parameter", "displayName": "Ssl Provider",
"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 name of the security
provider used for SSL connections. Default value is the defau [...]
"sslSecureRandomImplementation": { "kind": "parameter", "displayName":
"Ssl Secure Random Implementation", "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 SecureRandom PRNG
implementation to use for [...]
"sslTrustmanagerAlgorithm": { "kind": "parameter", "displayName": "Ssl
Trustmanager Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PKIX", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The algorithm used by
trust manager [...]
+ "sslTruststoreCertificates": { "kind": "parameter", "displayName": "Ssl
Truststore Certificates", "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": "Trusted certificates in
the format specified by 'ssl.trus [...]
"sslTruststoreLocation": { "kind": "parameter", "displayName": "Ssl
Truststore Location", "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 location of the
trust store file." },
- "sslTruststorePassword": { "kind": "parameter", "displayName": "Ssl
Truststore Password", "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 password for the
trust store file. If a password is not set a [...]
+ "sslTruststorePassword": { "kind": "parameter", "displayName": "Ssl
Truststore Password", "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 password for the
trust store file. If a password is not set, [...]
"sslTruststoreType": { "kind": "parameter", "displayName": "Ssl Truststore
Type", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
trust store file." }
}
}
diff --git a/components-starter/camel-corda-starter/pom.xml
b/components-starter/camel-corda-starter/pom.xml
index d667b96..158a2e5 100644
--- a/components-starter/camel-corda-starter/pom.xml
+++ b/components-starter/camel-corda-starter/pom.xml
@@ -41,6 +41,14 @@
<!--START OF GENERATED CODE-->
<exclusions>
<exclusion>
+ <groupId>ch.qos.logback</groupId>
+ <artifactId>logback-classic</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>ch.qos.logback</groupId>
+ <artifactId>logback-core</artifactId>
+ </exclusion>
+ <exclusion>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
</exclusion>
diff --git a/components-starter/camel-iota-starter/pom.xml
b/components-starter/camel-iota-starter/pom.xml
index 95d1ad5..758052f 100644
--- a/components-starter/camel-iota-starter/pom.xml
+++ b/components-starter/camel-iota-starter/pom.xml
@@ -38,6 +38,18 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-iota</artifactId>
<version>${camel-version}</version>
+ <!--START OF GENERATED CODE-->
+ <exclusions>
+ <exclusion>
+ <groupId>ch.qos.logback</groupId>
+ <artifactId>logback-classic</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>ch.qos.logback</groupId>
+ <artifactId>logback-core</artifactId>
+ </exclusion>
+ </exclusions>
+ <!--END OF GENERATED CODE-->
</dependency>
<!--START OF GENERATED CODE-->
<dependency>
diff --git
a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
index 8bc6f30..8de0c38 100644
---
a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
+++
b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
@@ -17,7 +17,7 @@ When using vertx-kafka with Spring Boot make sure to use the
following Maven dep
----
-The component supports 99 options, which are listed below.
+The component supports 104 options, which are listed below.
@@ -60,7 +60,7 @@ The component supports 99 options, which are listed below.
| *camel.component.vertx-kafka.key-serializer* | Serializer class for key that
implements the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.vertx-kafka.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 processe [...]
| *camel.component.vertx-kafka.linger-ms* | The producer groups together any
records that arrive in between request transmissions into a single batched
request. Normally this occurs only under load when records arrive faster than
they can be sent out. However in some circumstances the client may want to
reduce the number of requests even under moderate load. This setting
accomplishes this by adding a small amount of artificial delay—that is,
rather than immediately sending out a re [...]
-| *camel.component.vertx-kafka.max-block-ms* | The configuration controls how
long KafkaProducer.send() and KafkaProducer.partitionsFor() will block.These
methods can be blocked either because the buffer is full or metadata
unavailable.Blocking in the user-supplied serializers or partitioner will not
be counted against this timeout. The option is a long type. | 60000 | Long
+| *camel.component.vertx-kafka.max-block-ms* | The configuration controls how
long the KafkaProducer's send(), partitionsFor(), initTransactions(),
sendOffsetsToTransaction(), commitTransaction() and abortTransaction() methods
will block. For send() this timeout bounds the total time waiting for both
metadata fetch and buffer allocation (blocking in the user-supplied serializers
or partitioner is not counted against this timeout). For partitionsFor() this
timeout bounds the time spent wa [...]
| *camel.component.vertx-kafka.max-in-flight-requests-per-connection* | The
maximum number of unacknowledged requests the client will send on a single
connection before blocking. Note that if this setting is set to be greater than
1 and there are failed sends, there is a risk of message re-ordering due to
retries (i.e., if retries are enabled). | 5 | Integer
| *camel.component.vertx-kafka.max-partition-fetch-bytes* | The maximum amount
of data per-partition the server will return. Records are fetched in batches by
the consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). S [...]
| *camel.component.vertx-kafka.max-poll-interval-ms* | The maximum delay
between invocations of poll() when using consumer group management. This places
an upper bound on the amount of time that the consumer can be idle before
fetching more records. If poll() is not called before expiration of this
timeout, then the consumer is considered failed and the group will rebalance in
order to reassign the partitions to another member. For consumers using a
non-null group.instance.id which reach [...]
@@ -101,23 +101,28 @@ The component supports 99 options, which are listed below.
| *camel.component.vertx-kafka.seek-to-position* | Set if KafkaConsumer will
read from beginning or end on startup: beginning : read from beginning end :
read from end. | | String
| *camel.component.vertx-kafka.send-buffer-bytes* | The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the value is -1, the OS default
will be used. | 131072 | Integer
| *camel.component.vertx-kafka.session-timeout-ms* | The timeout used to
detect client failures when using Kafka's group management facility. The client
sends periodic heartbeats to indicate its liveness to the broker. If no
heartbeats are received by the broker before the expiration of this session
timeout, then the broker will remove this client from the group and initiate a
rebalance. Note that the value must be in the allowable range as configured in
the broker configuration by group [...]
+| *camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms* | The
maximum amount of time the client will wait for the socket connection to be
established. The connection setup timeout will increase exponentially for each
consecutive connection failure up to this maximum. To avoid connection storms,
a randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. The option is
a long type. | 127000 | Long
+| *camel.component.vertx-kafka.socket-connection-setup-timeout-ms* | The
amount of time the client will wait for the socket connection to be
established. If the connection is not built before the timeout elapses, clients
will close the socket channel. The option is a long type. | 10000 | Long
| *camel.component.vertx-kafka.ssl-cipher-suites* | A list of cipher suites.
This is a named combination of authentication, encryption, MAC and key exchange
algorithm used to negotiate the security settings for a network connection
using TLS or SSL network protocol. By default all the available cipher suites
are supported. | | String
| *camel.component.vertx-kafka.ssl-enabled-protocols* | The list of protocols
enabled for SSL connections. The default is 'TLSv1.2,TLSv1.3' when running with
Java 11 or newer, 'TLSv1.2' otherwise. With the default value for Java 11,
clients and servers will prefer TLSv1.3 if both support it and fallback to
TLSv1.2 otherwise (assuming both support at least TLSv1.2). This default should
be fine for most cases. Also see the config documentation for ssl.protocol. |
TLSv1.2,TLSv1.3 | String
| *camel.component.vertx-kafka.ssl-endpoint-identification-algorithm* | The
endpoint identification algorithm to validate server hostname using server
certificate. | https | String
| *camel.component.vertx-kafka.ssl-engine-factory-class* | The class of type
org.apache.kafka.common.security.auth.SslEngineFactory to provide SSLEngine
objects. Default value is
org.apache.kafka.common.security.ssl.DefaultSslEngineFactory | | String
-| *camel.component.vertx-kafka.ssl-key-password* | The password of the private
key in the key store file. This is optional for client. | | String
+| *camel.component.vertx-kafka.ssl-key-password* | The password of the private
key in the key store file orthe PEM key specified in ssl.keystore.key'. This is
required for clients only if two-way authentication is configured. | | String
| *camel.component.vertx-kafka.ssl-keymanager-algorithm* | The algorithm used
by key manager factory for SSL connections. Default value is the key manager
factory algorithm configured for the Java Virtual Machine. | SunX509 | String
+| *camel.component.vertx-kafka.ssl-keystore-certificate-chain* | Certificate
chain in the format specified by 'ssl.keystore.type'. Default SSL engine
factory supports only PEM format with a list of X.509 certificates | | String
+| *camel.component.vertx-kafka.ssl-keystore-key* | Private key in the format
specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM
format with PKCS#8 keys. If the key is encrypted, key password must be
specified using 'ssl.key.password' | | String
| *camel.component.vertx-kafka.ssl-keystore-location* | The location of the
key store file. This is optional for client and can be used for two-way
authentication for client. | | String
-| *camel.component.vertx-kafka.ssl-keystore-password* | The store password for
the key store file. This is optional for client and only needed if
ssl.keystore.location is configured. | | String
+| *camel.component.vertx-kafka.ssl-keystore-password* | The store password for
the key store file. This is optional for client and only needed if
'ssl.keystore.location' is configured. Key store password is not supported for
PEM format. | | String
| *camel.component.vertx-kafka.ssl-keystore-type* | The file format of the key
store file. This is optional for client. | JKS | String
| *camel.component.vertx-kafka.ssl-protocol* | The SSL protocol used to
generate the SSLContext. The default is 'TLSv1.3' when running with Java 11 or
newer, 'TLSv1.2' otherwise. This value should be fine for most use cases.
Allowed values in recent JVMs are 'TLSv1.2' and 'TLSv1.3'. 'TLS', 'TLSv1.1',
'SSL', 'SSLv2' and 'SSLv3' may be supported in older JVMs, but their usage is
discouraged due to known security vulnerabilities. With the default value for
this config and 'ssl.enabled.proto [...]
| *camel.component.vertx-kafka.ssl-provider* | The name of the security
provider used for SSL connections. Default value is the default security
provider of the JVM. | | String
| *camel.component.vertx-kafka.ssl-secure-random-implementation* | The
SecureRandom PRNG implementation to use for SSL cryptography operations. | |
String
| *camel.component.vertx-kafka.ssl-trustmanager-algorithm* | The algorithm
used by trust manager factory for SSL connections. Default value is the trust
manager factory algorithm configured for the Java Virtual Machine. | PKIX |
String
+| *camel.component.vertx-kafka.ssl-truststore-certificates* | Trusted
certificates in the format specified by 'ssl.truststore.type'. Default SSL
engine factory supports only PEM format with X.509 certificates. | | String
| *camel.component.vertx-kafka.ssl-truststore-location* | The location of the
trust store file. | | String
-| *camel.component.vertx-kafka.ssl-truststore-password* | The password for the
trust store file. If a password is not set access to the truststore is still
available, but integrity checking is disabled. | | String
+| *camel.component.vertx-kafka.ssl-truststore-password* | The password for the
trust store file. If a password is not set, trust store file configured will
still be used, but integrity checking is disabled. Trust store password is not
supported for PEM format. | | String
| *camel.component.vertx-kafka.ssl-truststore-type* | The file format of the
trust store file. | JKS | String
-| *camel.component.vertx-kafka.transaction-timeout-ms* | The maximum amount of
time in ms that the transaction coordinator will wait for a transaction status
update from the producer before proactively aborting the ongoing transaction.If
this value is larger than the transaction.max.timeout.ms setting in the broker,
the request will fail with a InvalidTransactionTimeout error. The option is a
int type. | 60000 | Integer
+| *camel.component.vertx-kafka.transaction-timeout-ms* | The maximum amount of
time in ms that the transaction coordinator will wait for a transaction status
update from the producer before proactively aborting the ongoing transaction.If
this value is larger than the transaction.max.timeout.ms setting in the broker,
the request will fail with a InvalidTxnTimeoutException error. The option is a
int type. | 60000 | Integer
| *camel.component.vertx-kafka.transactional-id* | The TransactionalId to use
for transactional delivery. This enables reliability semantics which span
multiple producer sessions since it allows the client to guarantee that
transactions using the same TransactionalId have been completed prior to
starting any new transactions. If no TransactionalId is provided, then the
producer is limited to idempotent delivery. If a TransactionalId is configured,
enable.idempotence is implied. By defaul [...]
| *camel.component.vertx-kafka.value-deserializer* | Deserializer class for
value that implements the org.apache.kafka.common.serialization.Deserializer
interface. | org.apache.kafka.common.serialization.StringDeserializer | String
| *camel.component.vertx-kafka.value-serializer* | Serializer class for value
that implements the org.apache.kafka.common.serialization.Serializer interface.
| org.apache.kafka.common.serialization.StringSerializer | String
diff --git
a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
index 42de0c0..d2c1215 100644
---
a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
+++
b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
@@ -182,6 +182,21 @@ public class VertxKafkaComponentConfiguration
*/
private Integer sendBufferBytes = 131072;
/**
+ * The maximum amount of time the client will wait for the socket
connection
+ * to be established. The connection setup timeout will increase
+ * exponentially for each consecutive connection failure up to this
maximum.
+ * To avoid connection storms, a randomization factor of 0.2 will be
applied
+ * to the timeout resulting in a random range between 20% below and 20%
+ * above the computed value. The option is a long type.
+ */
+ private Long socketConnectionSetupTimeoutMaxMs = 127000L;
+ /**
+ * The amount of time the client will wait for the socket connection to be
+ * established. If the connection is not built before the timeout elapses,
+ * clients will close the socket channel. The option is a long type.
+ */
+ private Long socketConnectionSetupTimeoutMs = 10000L;
+ /**
* Allow automatic topic creation on the broker when subscribing to or
* assigning a topic. A topic being subscribed to will be automatically
* created only if the broker allows for it using auto.create.topics.enable
@@ -502,11 +517,16 @@ public class VertxKafkaComponentConfiguration
*/
private Long lingerMs = 0L;
/**
- * The configuration controls how long KafkaProducer.send() and
- * KafkaProducer.partitionsFor() will block.These methods can be blocked
- * either because the buffer is full or metadata unavailable.Blocking in
the
- * user-supplied serializers or partitioner will not be counted against
this
- * timeout. The option is a long type.
+ * The configuration controls how long the KafkaProducer's send(),
+ * partitionsFor(), initTransactions(), sendOffsetsToTransaction(),
+ * commitTransaction() and abortTransaction() methods will block. For
send()
+ * this timeout bounds the total time waiting for both metadata fetch and
+ * buffer allocation (blocking in the user-supplied serializers or
+ * partitioner is not counted against this timeout). For partitionsFor()
+ * this timeout bounds the time spent waiting for metadata if it is
+ * unavailable. The transaction-related methods always block, but may
+ * timeout if the transaction coordinator could not be discovered or did
not
+ * respond within the timeout. The option is a long type.
*/
private Long maxBlockMs = 60000L;
/**
@@ -574,7 +594,7 @@ public class VertxKafkaComponentConfiguration
* wait for a transaction status update from the producer before
proactively
* aborting the ongoing transaction.If this value is larger than the
* transaction.max.timeout.ms setting in the broker, the request will fail
- * with a InvalidTransactionTimeout error. The option is a int type.
+ * with a InvalidTxnTimeoutException error. The option is a int type.
*/
private Integer transactionTimeoutMs = 60000;
/**
@@ -739,18 +759,32 @@ public class VertxKafkaComponentConfiguration
*/
private String sslKeymanagerAlgorithm = "SunX509";
/**
- * The password of the private key in the key store file. This is optional
- * for client.
+ * The password of the private key in the key store file orthe PEM key
+ * specified in ssl.keystore.key'. This is required for clients only if
+ * two-way authentication is configured.
*/
private String sslKeyPassword;
/**
+ * Certificate chain in the format specified by 'ssl.keystore.type'.
Default
+ * SSL engine factory supports only PEM format with a list of X.509
+ * certificates
+ */
+ private String sslKeystoreCertificateChain;
+ /**
+ * Private key in the format specified by 'ssl.keystore.type'. Default SSL
+ * engine factory supports only PEM format with PKCS#8 keys. If the key is
+ * encrypted, key password must be specified using 'ssl.key.password'
+ */
+ private String sslKeystoreKey;
+ /**
* The location of the key store file. This is optional for client and can
* be used for two-way authentication for client.
*/
private String sslKeystoreLocation;
/**
* The store password for the key store file. This is optional for client
- * and only needed if ssl.keystore.location is configured.
+ * and only needed if 'ssl.keystore.location' is configured. Key store
+ * password is not supported for PEM format.
*/
private String sslKeystorePassword;
/**
@@ -787,12 +821,19 @@ public class VertxKafkaComponentConfiguration
*/
private String sslTrustmanagerAlgorithm = "PKIX";
/**
+ * Trusted certificates in the format specified by 'ssl.truststore.type'.
+ * Default SSL engine factory supports only PEM format with X.509
+ * certificates.
+ */
+ private String sslTruststoreCertificates;
+ /**
* The location of the trust store file.
*/
private String sslTruststoreLocation;
/**
- * The password for the trust store file. If a password is not set access
to
- * the truststore is still available, but integrity checking is disabled.
+ * The password for the trust store file. If a password is not set, trust
+ * store file configured will still be used, but integrity checking is
+ * disabled. Trust store password is not supported for PEM format.
*/
private String sslTruststorePassword;
/**
@@ -961,6 +1002,24 @@ public class VertxKafkaComponentConfiguration
this.sendBufferBytes = sendBufferBytes;
}
+ public Long getSocketConnectionSetupTimeoutMaxMs() {
+ return socketConnectionSetupTimeoutMaxMs;
+ }
+
+ public void setSocketConnectionSetupTimeoutMaxMs(
+ Long socketConnectionSetupTimeoutMaxMs) {
+ this.socketConnectionSetupTimeoutMaxMs =
socketConnectionSetupTimeoutMaxMs;
+ }
+
+ public Long getSocketConnectionSetupTimeoutMs() {
+ return socketConnectionSetupTimeoutMs;
+ }
+
+ public void setSocketConnectionSetupTimeoutMs(
+ Long socketConnectionSetupTimeoutMs) {
+ this.socketConnectionSetupTimeoutMs = socketConnectionSetupTimeoutMs;
+ }
+
public Boolean getAllowAutoCreateTopics() {
return allowAutoCreateTopics;
}
@@ -1517,6 +1576,23 @@ public class VertxKafkaComponentConfiguration
this.sslKeyPassword = sslKeyPassword;
}
+ public String getSslKeystoreCertificateChain() {
+ return sslKeystoreCertificateChain;
+ }
+
+ public void setSslKeystoreCertificateChain(
+ String sslKeystoreCertificateChain) {
+ this.sslKeystoreCertificateChain = sslKeystoreCertificateChain;
+ }
+
+ public String getSslKeystoreKey() {
+ return sslKeystoreKey;
+ }
+
+ public void setSslKeystoreKey(String sslKeystoreKey) {
+ this.sslKeystoreKey = sslKeystoreKey;
+ }
+
public String getSslKeystoreLocation() {
return sslKeystoreLocation;
}
@@ -1574,6 +1650,14 @@ public class VertxKafkaComponentConfiguration
this.sslTrustmanagerAlgorithm = sslTrustmanagerAlgorithm;
}
+ public String getSslTruststoreCertificates() {
+ return sslTruststoreCertificates;
+ }
+
+ public void setSslTruststoreCertificates(String sslTruststoreCertificates)
{
+ this.sslTruststoreCertificates = sslTruststoreCertificates;
+ }
+
public String getSslTruststoreLocation() {
return sslTruststoreLocation;
}
diff --git a/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
b/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
index 8bc6f30..8de0c38 100644
--- a/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
+++ b/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
@@ -17,7 +17,7 @@ When using vertx-kafka with Spring Boot make sure to use the
following Maven dep
----
-The component supports 99 options, which are listed below.
+The component supports 104 options, which are listed below.
@@ -60,7 +60,7 @@ The component supports 99 options, which are listed below.
| *camel.component.vertx-kafka.key-serializer* | Serializer class for key that
implements the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.vertx-kafka.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 processe [...]
| *camel.component.vertx-kafka.linger-ms* | The producer groups together any
records that arrive in between request transmissions into a single batched
request. Normally this occurs only under load when records arrive faster than
they can be sent out. However in some circumstances the client may want to
reduce the number of requests even under moderate load. This setting
accomplishes this by adding a small amount of artificial delay—that is,
rather than immediately sending out a re [...]
-| *camel.component.vertx-kafka.max-block-ms* | The configuration controls how
long KafkaProducer.send() and KafkaProducer.partitionsFor() will block.These
methods can be blocked either because the buffer is full or metadata
unavailable.Blocking in the user-supplied serializers or partitioner will not
be counted against this timeout. The option is a long type. | 60000 | Long
+| *camel.component.vertx-kafka.max-block-ms* | The configuration controls how
long the KafkaProducer's send(), partitionsFor(), initTransactions(),
sendOffsetsToTransaction(), commitTransaction() and abortTransaction() methods
will block. For send() this timeout bounds the total time waiting for both
metadata fetch and buffer allocation (blocking in the user-supplied serializers
or partitioner is not counted against this timeout). For partitionsFor() this
timeout bounds the time spent wa [...]
| *camel.component.vertx-kafka.max-in-flight-requests-per-connection* | The
maximum number of unacknowledged requests the client will send on a single
connection before blocking. Note that if this setting is set to be greater than
1 and there are failed sends, there is a risk of message re-ordering due to
retries (i.e., if retries are enabled). | 5 | Integer
| *camel.component.vertx-kafka.max-partition-fetch-bytes* | The maximum amount
of data per-partition the server will return. Records are fetched in batches by
the consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). S [...]
| *camel.component.vertx-kafka.max-poll-interval-ms* | The maximum delay
between invocations of poll() when using consumer group management. This places
an upper bound on the amount of time that the consumer can be idle before
fetching more records. If poll() is not called before expiration of this
timeout, then the consumer is considered failed and the group will rebalance in
order to reassign the partitions to another member. For consumers using a
non-null group.instance.id which reach [...]
@@ -101,23 +101,28 @@ The component supports 99 options, which are listed below.
| *camel.component.vertx-kafka.seek-to-position* | Set if KafkaConsumer will
read from beginning or end on startup: beginning : read from beginning end :
read from end. | | String
| *camel.component.vertx-kafka.send-buffer-bytes* | The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the value is -1, the OS default
will be used. | 131072 | Integer
| *camel.component.vertx-kafka.session-timeout-ms* | The timeout used to
detect client failures when using Kafka's group management facility. The client
sends periodic heartbeats to indicate its liveness to the broker. If no
heartbeats are received by the broker before the expiration of this session
timeout, then the broker will remove this client from the group and initiate a
rebalance. Note that the value must be in the allowable range as configured in
the broker configuration by group [...]
+| *camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms* | The
maximum amount of time the client will wait for the socket connection to be
established. The connection setup timeout will increase exponentially for each
consecutive connection failure up to this maximum. To avoid connection storms,
a randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. The option is
a long type. | 127000 | Long
+| *camel.component.vertx-kafka.socket-connection-setup-timeout-ms* | The
amount of time the client will wait for the socket connection to be
established. If the connection is not built before the timeout elapses, clients
will close the socket channel. The option is a long type. | 10000 | Long
| *camel.component.vertx-kafka.ssl-cipher-suites* | A list of cipher suites.
This is a named combination of authentication, encryption, MAC and key exchange
algorithm used to negotiate the security settings for a network connection
using TLS or SSL network protocol. By default all the available cipher suites
are supported. | | String
| *camel.component.vertx-kafka.ssl-enabled-protocols* | The list of protocols
enabled for SSL connections. The default is 'TLSv1.2,TLSv1.3' when running with
Java 11 or newer, 'TLSv1.2' otherwise. With the default value for Java 11,
clients and servers will prefer TLSv1.3 if both support it and fallback to
TLSv1.2 otherwise (assuming both support at least TLSv1.2). This default should
be fine for most cases. Also see the config documentation for ssl.protocol. |
TLSv1.2,TLSv1.3 | String
| *camel.component.vertx-kafka.ssl-endpoint-identification-algorithm* | The
endpoint identification algorithm to validate server hostname using server
certificate. | https | String
| *camel.component.vertx-kafka.ssl-engine-factory-class* | The class of type
org.apache.kafka.common.security.auth.SslEngineFactory to provide SSLEngine
objects. Default value is
org.apache.kafka.common.security.ssl.DefaultSslEngineFactory | | String
-| *camel.component.vertx-kafka.ssl-key-password* | The password of the private
key in the key store file. This is optional for client. | | String
+| *camel.component.vertx-kafka.ssl-key-password* | The password of the private
key in the key store file orthe PEM key specified in ssl.keystore.key'. This is
required for clients only if two-way authentication is configured. | | String
| *camel.component.vertx-kafka.ssl-keymanager-algorithm* | The algorithm used
by key manager factory for SSL connections. Default value is the key manager
factory algorithm configured for the Java Virtual Machine. | SunX509 | String
+| *camel.component.vertx-kafka.ssl-keystore-certificate-chain* | Certificate
chain in the format specified by 'ssl.keystore.type'. Default SSL engine
factory supports only PEM format with a list of X.509 certificates | | String
+| *camel.component.vertx-kafka.ssl-keystore-key* | Private key in the format
specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM
format with PKCS#8 keys. If the key is encrypted, key password must be
specified using 'ssl.key.password' | | String
| *camel.component.vertx-kafka.ssl-keystore-location* | The location of the
key store file. This is optional for client and can be used for two-way
authentication for client. | | String
-| *camel.component.vertx-kafka.ssl-keystore-password* | The store password for
the key store file. This is optional for client and only needed if
ssl.keystore.location is configured. | | String
+| *camel.component.vertx-kafka.ssl-keystore-password* | The store password for
the key store file. This is optional for client and only needed if
'ssl.keystore.location' is configured. Key store password is not supported for
PEM format. | | String
| *camel.component.vertx-kafka.ssl-keystore-type* | The file format of the key
store file. This is optional for client. | JKS | String
| *camel.component.vertx-kafka.ssl-protocol* | The SSL protocol used to
generate the SSLContext. The default is 'TLSv1.3' when running with Java 11 or
newer, 'TLSv1.2' otherwise. This value should be fine for most use cases.
Allowed values in recent JVMs are 'TLSv1.2' and 'TLSv1.3'. 'TLS', 'TLSv1.1',
'SSL', 'SSLv2' and 'SSLv3' may be supported in older JVMs, but their usage is
discouraged due to known security vulnerabilities. With the default value for
this config and 'ssl.enabled.proto [...]
| *camel.component.vertx-kafka.ssl-provider* | The name of the security
provider used for SSL connections. Default value is the default security
provider of the JVM. | | String
| *camel.component.vertx-kafka.ssl-secure-random-implementation* | The
SecureRandom PRNG implementation to use for SSL cryptography operations. | |
String
| *camel.component.vertx-kafka.ssl-trustmanager-algorithm* | The algorithm
used by trust manager factory for SSL connections. Default value is the trust
manager factory algorithm configured for the Java Virtual Machine. | PKIX |
String
+| *camel.component.vertx-kafka.ssl-truststore-certificates* | Trusted
certificates in the format specified by 'ssl.truststore.type'. Default SSL
engine factory supports only PEM format with X.509 certificates. | | String
| *camel.component.vertx-kafka.ssl-truststore-location* | The location of the
trust store file. | | String
-| *camel.component.vertx-kafka.ssl-truststore-password* | The password for the
trust store file. If a password is not set access to the truststore is still
available, but integrity checking is disabled. | | String
+| *camel.component.vertx-kafka.ssl-truststore-password* | The password for the
trust store file. If a password is not set, trust store file configured will
still be used, but integrity checking is disabled. Trust store password is not
supported for PEM format. | | String
| *camel.component.vertx-kafka.ssl-truststore-type* | The file format of the
trust store file. | JKS | String
-| *camel.component.vertx-kafka.transaction-timeout-ms* | The maximum amount of
time in ms that the transaction coordinator will wait for a transaction status
update from the producer before proactively aborting the ongoing transaction.If
this value is larger than the transaction.max.timeout.ms setting in the broker,
the request will fail with a InvalidTransactionTimeout error. The option is a
int type. | 60000 | Integer
+| *camel.component.vertx-kafka.transaction-timeout-ms* | The maximum amount of
time in ms that the transaction coordinator will wait for a transaction status
update from the producer before proactively aborting the ongoing transaction.If
this value is larger than the transaction.max.timeout.ms setting in the broker,
the request will fail with a InvalidTxnTimeoutException error. The option is a
int type. | 60000 | Integer
| *camel.component.vertx-kafka.transactional-id* | The TransactionalId to use
for transactional delivery. This enables reliability semantics which span
multiple producer sessions since it allows the client to guarantee that
transactions using the same TransactionalId have been completed prior to
starting any new transactions. If no TransactionalId is provided, then the
producer is limited to idempotent delivery. If a TransactionalId is configured,
enable.idempotence is implied. By defaul [...]
| *camel.component.vertx-kafka.value-deserializer* | Deserializer class for
value that implements the org.apache.kafka.common.serialization.Deserializer
interface. | org.apache.kafka.common.serialization.StringDeserializer | String
| *camel.component.vertx-kafka.value-serializer* | Serializer class for value
that implements the org.apache.kafka.common.serialization.Serializer interface.
| org.apache.kafka.common.serialization.StringSerializer | String
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index 36c2c9e..bb794b7 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -129,7 +129,7 @@
<dependency>
<groupId>com.thoughtworks.xstream</groupId>
<artifactId>xstream</artifactId>
- <version>1.4.14</version>
+ <version>1.4.15</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
