This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 3d07945 CAMEL-17284: upgrade Kafka clients to 3.1.0
3d07945 is described below
commit 3d079458eda8de580fdb8e5075ad8be10f09c4c2
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Jan 28 15:03:32 2022 +0100
CAMEL-17284: upgrade Kafka clients to 3.1.0
---
.../camel/catalog/components/vertx-kafka.json | 64 ++++++----------------
1 file changed, 18 insertions(+), 46 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 f8d1c56..aca8dd2 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
@@ -24,7 +24,7 @@
"componentProperties": {
"additionalProperties": { "kind": "property", "displayName": "Additional
Properties", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
"prefix": "additionalProperties.", "multiValue": true, "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descrip [...]
"bootstrapServers": { "kind": "property", "displayName": "Bootstrap
Servers", "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 host\/port
pairs to use for establishing the initial connection to the Kafka c [...]
- "clientDnsLookup": { "kind": "property", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "use_all_dns_ips",
"resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configurati [...]
+ "clientDnsLookup": { "kind": "property", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "default",
"use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": " [...]
"clientId": { "kind": "property", "displayName": "Client Id", "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": "An id string to pass to
the server when making requests. The purpose of this is to be able to track the
[...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
"connectionsMaxIdleMs": { "kind": "property", "displayName": "Connections
Max Idle Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "9m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Close idle connections
after the number of milliseconds specified [...]
@@ -65,26 +65,26 @@
"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(). 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,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfi [...]
+ "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": "45s", "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 [...]
+ "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 [...]
"valueDeserializer": { "kind": "property", "displayName": "Value
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": "Deseri [...]
"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommitFactory",
"deprecated": false, "autowired": true, "secret": false, "description":
"Factory to use for creating
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances.
This allows to plugin [...]
- "acks": { "kind": "property", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "all",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer requires [...]
- "batchSize": { "kind": "property", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multip [...]
+ "acks": { "kind": "property", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer requires t [...]
+ "batchSize": { "kind": "property", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multip [...]
"bufferMemory": { "kind": "property", "displayName": "Buffer Memory",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 33554432, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The total bytes of
memory the producer can use to buffer records waiting to b [...]
"compressionType": { "kind": "property", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "none", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The compression type for
all data generated by the producer. T [...]
"deliveryTimeoutMs": { "kind": "property", "displayName": "Delivery
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "2m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "An upper bound on the
time to report success or failure after a call t [...]
- "enableIdempotence": { "kind": "property", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "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": "When set to 'true', the
producer will ensure that exactly one copy o [...]
+ "enableIdempotence": { "kind": "property", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "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": "When set to 'true', the
producer will ensure that exactly one copy [...]
"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 [...]
+ "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 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 [...]
+ "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": "A [...]
+ "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 [...]
@@ -102,25 +102,11 @@
"saslKerberosTicketRenewWindowFactor": { "kind": "property",
"displayName": "Sasl Kerberos Ticket Renew Window Factor", "group": "security",
"label": "common,security", "required": false, "type": "number", "javaType":
"double", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0.8, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread will sleep
[...]
"saslLoginCallbackHandlerClass": { "kind": "property", "displayName":
"Sasl Login 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 login callbac [...]
"saslLoginClass": { "kind": "property", "displayName": "Sasl Login 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 class that implements the Login interface. For bro [...]
- "saslLoginConnectTimeoutMs": { "kind": "property", "displayName": "Sasl
Login Connect Timeout Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the external [...]
- "saslLoginReadTimeoutMs": { "kind": "property", "displayName": "Sasl Login
Read Timeout Ms", "group": "security", "label": "common,security", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the external authe [...]
"saslLoginRefreshBufferSeconds": { "kind": "property", "displayName":
"Sasl Login Refresh Buffer Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"300", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of buffer
time before cr [...]
"saslLoginRefreshMinPeriodSeconds": { "kind": "property", "displayName":
"Sasl Login Refresh Min Period Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "60",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The desired minimum time
for [...]
"saslLoginRefreshWindowFactor": { "kind": "property", "displayName": "Sasl
Login Refresh Window Factor", "group": "security", "label": "common,security",
"required": false, "type": "number", "javaType": "double", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 0.8, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login refresh thread
will sleep until t [...]
"saslLoginRefreshWindowJitter": { "kind": "property", "displayName": "Sasl
Login Refresh Window Jitter", "group": "security", "label": "common,security",
"required": false, "type": "number", "javaType": "double", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 0.05,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
random jitter re [...]
- "saslLoginRetryBackoffMaxMs": { "kind": "property", "displayName": "Sasl
Login Retry Backoff Max Ms", "group": "security", "label": "common,security",
"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 (optional) value in
milliseconds for [...]
- "saslLoginRetryBackoffMs": { "kind": "property", "displayName": "Sasl
Login Retry Backoff Ms", "group": "security", "label": "common,security",
"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 (optional) value in
milliseconds for the [...]
"saslMechanism": { "kind": "property", "displayName": "Sasl Mechanism",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "GSSAPI", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "SASL mechanism used for
client connections. This may be a [...]
- "saslOauthbearerClockSkewSeconds": { "kind": "property", "displayName":
"Sasl Oauthbearer Clock Skew Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 30,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
seconds to a [...]
- "saslOauthbearerExpectedAudience": { "kind": "property", "displayName":
"Sasl Oauthbearer Expected Audience", "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 (optional)
comma-delimited setting for th [...]
- "saslOauthbearerExpectedIssuer": { "kind": "property", "displayName":
"Sasl Oauthbearer Expected Issuer", "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 (optional) setting
for the broker to use to v [...]
- "saslOauthbearerJwksEndpointRefreshMs": { "kind": "property",
"displayName": "Sasl Oauthbearer Jwks Endpoint Refresh Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1h", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value
[...]
- "saslOauthbearerJwksEndpointRetryBackoffMaxMs": { "kind": "property",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Max Ms", "group":
"security", "label": "common,security", "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": "Th [...]
- "saslOauthbearerJwksEndpointRetryBackoffMs": { "kind": "property",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Ms", "group":
"security", "label": "common,security", "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 (op [...]
- "saslOauthbearerJwksEndpointUrl": { "kind": "property", "displayName":
"Sasl Oauthbearer Jwks Endpoint Url", "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 OAuth\/OIDC provider
URL from which the pr [...]
- "saslOauthbearerScopeClaimName": { "kind": "property", "displayName":
"Sasl Oauthbearer Scope Claim Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "scope", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for the
[...]
- "saslOauthbearerSubClaimName": { "kind": "property", "displayName": "Sasl
Oauthbearer Sub Claim Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"sub", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for the
subje [...]
- "saslOauthbearerTokenEndpointUrl": { "kind": "property", "displayName":
"Sasl Oauthbearer Token Endpoint Url", "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 URL for the
OAuth\/OIDC identity provide [...]
"securityProtocol": { "kind": "property", "displayName": "Security
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PLAINTEXT",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Protocol used to
communicate with brokers. Valid [...]
"securityProviders": { "kind": "property", "displayName": "Security
Providers", "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": "A list of configurable
creator classes each returning a provider implementi [...]
"sslCipherSuites": { "kind": "property", "displayName": "Ssl Cipher
Suites", "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": "A list of cipher suites.
This is a named combination of authentication, encryp [...]
@@ -147,7 +133,7 @@
"topic": { "kind": "path", "displayName": "Topic", "group": "common",
"label": "common", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Name of the topic to
use. On the consumer you can use comma to separate multiple topics. A pr [...]
"additionalProperties": { "kind": "parameter", "displayName": "Additional
Properties", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
"prefix": "additionalProperties.", "multiValue": true, "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descri [...]
"bootstrapServers": { "kind": "parameter", "displayName": "Bootstrap
Servers", "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 host\/port
pairs to use for establishing the initial connection to the Kafka [...]
- "clientDnsLookup": { "kind": "parameter", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "use_all_dns_ips",
"resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configurat [...]
+ "clientDnsLookup": { "kind": "parameter", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "default",
"use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": [...]
"clientId": { "kind": "parameter", "displayName": "Client Id", "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": "An id string to pass to
the server when making requests. The purpose of this is to be able to track the
[...]
"connectionsMaxIdleMs": { "kind": "parameter", "displayName": "Connections
Max Idle Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "9m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Close idle connections
after the number of milliseconds specified [...]
"headerFilterStrategy": { "kind": "parameter", "displayName": "Header
Filter Strategy", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "To use a custom
HeaderFilterStrategy to filter header [...]
@@ -187,27 +173,27 @@
"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(). 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,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConf [...]
+ "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": "45s", "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 [...]
+ "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 [...]
"valueDeserializer": { "kind": "parameter", "displayName": "Value
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": "Deser [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
- "acks": { "kind": "parameter", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "all",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer require [...]
- "batchSize": { "kind": "parameter", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multi [...]
+ "acks": { "kind": "parameter", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer requires [...]
+ "batchSize": { "kind": "parameter", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multi [...]
"bufferMemory": { "kind": "parameter", "displayName": "Buffer Memory",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 33554432, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The total bytes of
memory the producer can use to buffer records waiting to [...]
"compressionType": { "kind": "parameter", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "none", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The compression type for
all data generated by the producer. [...]
"deliveryTimeoutMs": { "kind": "parameter", "displayName": "Delivery
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "2m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "An upper bound on the
time to report success or failure after a call [...]
- "enableIdempotence": { "kind": "parameter", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "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": "When set to 'true', the
producer will ensure that exactly one copy [...]
+ "enableIdempotence": { "kind": "parameter", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "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": "When set to 'true', the
producer will ensure that exactly one copy [...]
"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 [...]
+ "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 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 [...]
+ "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": "A [...]
+ "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 [...]
@@ -221,25 +207,11 @@
"saslKerberosTicketRenewWindowFactor": { "kind": "parameter",
"displayName": "Sasl Kerberos Ticket Renew Window Factor", "group": "security",
"label": "common,security", "required": false, "type": "number", "javaType":
"double", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0.8, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread will sleep
[...]
"saslLoginCallbackHandlerClass": { "kind": "parameter", "displayName":
"Sasl Login 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 login callba [...]
"saslLoginClass": { "kind": "parameter", "displayName": "Sasl Login
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 class that implements the Login interface. For br [...]
- "saslLoginConnectTimeoutMs": { "kind": "parameter", "displayName": "Sasl
Login Connect Timeout Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the externa [...]
- "saslLoginReadTimeoutMs": { "kind": "parameter", "displayName": "Sasl
Login Read Timeout Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the external auth [...]
"saslLoginRefreshBufferSeconds": { "kind": "parameter", "displayName":
"Sasl Login Refresh Buffer Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"300", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of buffer
time before c [...]
"saslLoginRefreshMinPeriodSeconds": { "kind": "parameter", "displayName":
"Sasl Login Refresh Min Period Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "60",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The desired minimum time
for [...]
"saslLoginRefreshWindowFactor": { "kind": "parameter", "displayName":
"Sasl Login Refresh Window Factor", "group": "security", "label":
"common,security", "required": false, "type": "number", "javaType": "double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.8,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login refresh thread
will sleep until [...]
"saslLoginRefreshWindowJitter": { "kind": "parameter", "displayName":
"Sasl Login Refresh Window Jitter", "group": "security", "label":
"common,security", "required": false, "type": "number", "javaType": "double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.05,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
random jitter r [...]
- "saslLoginRetryBackoffMaxMs": { "kind": "parameter", "displayName": "Sasl
Login Retry Backoff Max Ms", "group": "security", "label": "common,security",
"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 (optional) value in
milliseconds fo [...]
- "saslLoginRetryBackoffMs": { "kind": "parameter", "displayName": "Sasl
Login Retry Backoff Ms", "group": "security", "label": "common,security",
"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 (optional) value in
milliseconds for the [...]
"saslMechanism": { "kind": "parameter", "displayName": "Sasl Mechanism",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "GSSAPI", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "SASL mechanism used for
client connections. This may be [...]
- "saslOauthbearerClockSkewSeconds": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Clock Skew Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 30,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
seconds to [...]
- "saslOauthbearerExpectedAudience": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Expected Audience", "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 (optional)
comma-delimited setting for t [...]
- "saslOauthbearerExpectedIssuer": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Expected Issuer", "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 (optional) setting
for the broker to use to [...]
- "saslOauthbearerJwksEndpointRefreshMs": { "kind": "parameter",
"displayName": "Sasl Oauthbearer Jwks Endpoint Refresh Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1h", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value
[...]
- "saslOauthbearerJwksEndpointRetryBackoffMaxMs": { "kind": "parameter",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Max Ms", "group":
"security", "label": "common,security", "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": "T [...]
- "saslOauthbearerJwksEndpointRetryBackoffMs": { "kind": "parameter",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Ms", "group":
"security", "label": "common,security", "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 (o [...]
- "saslOauthbearerJwksEndpointUrl": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Jwks Endpoint Url", "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 OAuth\/OIDC provider
URL from which the p [...]
- "saslOauthbearerScopeClaimName": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Scope Claim Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "scope", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for th
[...]
- "saslOauthbearerSubClaimName": { "kind": "parameter", "displayName": "Sasl
Oauthbearer Sub Claim Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"sub", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for the
subj [...]
- "saslOauthbearerTokenEndpointUrl": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Token Endpoint Url", "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 URL for the
OAuth\/OIDC identity provid [...]
"securityProtocol": { "kind": "parameter", "displayName": "Security
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PLAINTEXT",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Protocol used to
communicate with brokers. Vali [...]
"securityProviders": { "kind": "parameter", "displayName": "Security
Providers", "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": "A list of configurable
creator classes each returning a provider implement [...]
"sslCipherSuites": { "kind": "parameter", "displayName": "Ssl Cipher
Suites", "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": "A list of cipher suites.
This is a named combination of authentication, encry [...]
