You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/01/27 13:02:32 UTC
[camel-spring-boot] branch main updated: CAMEL-17284: upgrade Kafka clients to 3.1.0
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new b21bd29 CAMEL-17284: upgrade Kafka clients to 3.1.0
b21bd29 is described below
commit b21bd29172750ff4a0dfe7b32f969589df5a3a79
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Jan 27 14:02:17 2022 +0100
CAMEL-17284: upgrade Kafka clients to 3.1.0
---
.../springboot/catalog/components/vertx-kafka.json | 64 +++--
.../src/main/docs/vertx-kafka.json | 114 +++++++-
.../VertxKafkaComponentConfiguration.java | 311 +++++++++++++++++++--
3 files changed, 439 insertions(+), 50 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 59c4938..17f5bdd 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
@@ -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": [ "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": " [...]
+ "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 [...]
"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", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "descripti [...]
+ "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 [...]
"seekToOffset": { "kind": "property", "displayName": "Seek To Offset", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from a particular offset on startup. This config will take pr [...]
"seekToPosition": { "kind": "property", "displayName": "Seek To Position", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from beginning or end on [...]
- "sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect client failures when using Kafka's group man [...]
+ "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 [...]
"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": "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 [...]
+ "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 [...]
"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": 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 [...]
+ "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 [...]
"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": "Pa [...]
+ "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 [...]
"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,11 +102,25 @@
"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 [...]
@@ -133,7 +147,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": [ "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": [...]
+ "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 [...]
"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 [...]
@@ -173,27 +187,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", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "descript [...]
+ "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 [...]
"seekToOffset": { "kind": "parameter", "displayName": "Seek To Offset", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from a particular offset on startup. This config will take p [...]
"seekToPosition": { "kind": "parameter", "displayName": "Seek To Position", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from beginning or end o [...]
- "sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect client failures when using Kafka's group ma [...]
+ "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 [...]
"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": "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 [...]
+ "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 [...]
"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": 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 [...]
+ "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 [...]
"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": "P [...]
+ "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 [...]
"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 [...]
@@ -207,11 +221,25 @@
"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 [...]
diff --git a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka.json b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka.json
index 62a6c51..3f6a262 100644
--- a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka.json
+++ b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka.json
@@ -18,7 +18,7 @@
"type": "java.lang.String",
"description": "The number of acknowledgments the producer requires the leader to have received before considering a request complete. This controls the durability of records that are sent. The following settings are allowed: acks=0 If set to zero then the producer will not wait for any acknowledgment from the server at all. The record will be immediately added to the socket buffer and considered sent. No guarantee can be made that the server has received the record in this case, a [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
- "defaultValue": "1"
+ "defaultValue": "all"
},
{
"name": "camel.component.vertx-kafka.additional-properties",
@@ -64,7 +64,7 @@
{
"name": "camel.component.vertx-kafka.batch-size",
"type": "java.lang.Integer",
- "description": "The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition. This helps performance on both the client and the server. This configuration controls the default batch size in bytes. No attempt will be made to batch records larger than this size. Requests sent to brokers will contain multiple batches, one for each partition with data available to be sent. A small batch size will make batching le [...]
+ "description": "The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition. This helps performance on both the client and the server. This configuration controls the default batch size in bytes. No attempt will be made to batch records larger than this size. Requests sent to brokers will contain multiple batches, one for each partition with data available to be sent. A small batch size will make batching le [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
"defaultValue": 16384
},
@@ -98,7 +98,7 @@
{
"name": "camel.component.vertx-kafka.client-dns-lookup",
"type": "java.lang.String",
- "description": "Controls how the client uses DNS lookups. If set to use_all_dns_ips, connect to each returned IP address in sequence until a successful connection is established. After a disconnection, the next IP is used. Once all IPs have been used once, the client resolves the IP(s) from the hostname again (both the JVM and the OS cache DNS name lookups, however). If set to resolve_canonical_bootstrap_servers_only, resolve each bootstrap address into a list of canonical names. A [...]
+ "description": "Controls how the client uses DNS lookups. If set to use_all_dns_ips, connect to each returned IP address in sequence until a successful connection is established. After a disconnection, the next IP is used. Once all IPs have been used once, the client resolves the IP(s) from the hostname again (both the JVM and the OS cache DNS name lookups, however). If set to resolve_canonical_bootstrap_servers_only, resolve each bootstrap address into a list of canonical names. A [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
"defaultValue": "use_all_dns_ips"
},
@@ -163,9 +163,9 @@
{
"name": "camel.component.vertx-kafka.enable-idempotence",
"type": "java.lang.Boolean",
- "description": "When set to 'true', the producer will ensure that exactly one copy of each message is written in the stream. If 'false', producer retries due to broker failures, etc., may write duplicates of the retried message in the stream. Note that enabling idempotence requires max.in.flight.requests.per.connection to be less than or equal to 5, retries to be greater than 0 and acks must be 'all'. If these values are not explicitly set by the user, suitable values will be chose [...]
+ "description": "When set to 'true', the producer will ensure that exactly one copy of each message is written in the stream. If 'false', producer retries due to broker failures, etc., may write duplicates of the retried message in the stream. Note that enabling idempotence requires max.in.flight.requests.per.connection to be less than or equal to 5 (with message ordering preserved for any allowable value), retries to be greater than 0, and acks must be 'all'. If these values are no [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
- "defaultValue": false
+ "defaultValue": true
},
{
"name": "camel.component.vertx-kafka.enabled",
@@ -269,7 +269,7 @@
{
"name": "camel.component.vertx-kafka.linger-ms",
"type": "java.lang.Long",
- "description": "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 record the producer will [...]
+ "description": "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 record, the producer wil [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
"defaultValue": 0
},
@@ -283,7 +283,7 @@
{
"name": "camel.component.vertx-kafka.max-in-flight-requests-per-connection",
"type": "java.lang.Integer",
- "description": "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).",
+ "description": "The maximum number of unacknowledged requests the client will send on a single connection before blocking. Note that if this config is set to be greater than 1 and enable.idempotence is set to false, there is a risk of message re-ordering after a failed send due to retries (i.e., if retries are enabled).",
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
"defaultValue": 5
},
@@ -359,9 +359,9 @@
{
"name": "camel.component.vertx-kafka.partition-assignment-strategy",
"type": "java.lang.String",
- "description": "A list of class names or class types, ordered by preference, of supported partition assignment strategies that the client will use to distribute partition ownership amongst consumer instances when group management is used. Available options are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor, which works on a per-topic basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions to consumers in a round-robin fashion.org.apache [...]
+ "description": "A list of class names or class types, ordered by preference, of supported partition assignment strategies that the client will use to distribute partition ownership amongst consumer instances when group management is used. Available options are:org.apache.kafka.clients.consumer.RangeAssignor: Assigns partitions on a per-topic basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions to consumers in a round-robin fashion.org.apache.kafka.clients. [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
- "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor"
+ "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor"
},
{
"name": "camel.component.vertx-kafka.partition-id",
@@ -372,7 +372,7 @@
{
"name": "camel.component.vertx-kafka.partitioner-class",
"type": "java.lang.String",
- "description": "Partitioner class that implements the org.apache.kafka.clients.producer.Partitioner interface.",
+ "description": "A class to use to determine which partition to be send to when produce the records. Available options are:org.apache.kafka.clients.producer.internals.DefaultPartitioner: The default partitioner. This strategy will try sticking to a partition until the batch is full, or linger.ms is up. It works with the strategy:If no partition is specified but a key is present, choose a partition based on a hash of the keyIf no partition or key is present, choose the sticky partiti [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
"defaultValue": "org.apache.kafka.clients.producer.internals.DefaultPartitioner"
},
@@ -475,6 +475,18 @@
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
},
{
+ "name": "camel.component.vertx-kafka.sasl-login-connect-timeout-ms",
+ "type": "java.lang.Integer",
+ "description": "The (optional) value in milliseconds for the external authentication provider connection timeout. Currently applies only to OAUTHBEARER. The option is a java.lang.Integer type.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-login-read-timeout-ms",
+ "type": "java.lang.Integer",
+ "description": "The (optional) value in milliseconds for the external authentication provider read timeout. Currently applies only to OAUTHBEARER. The option is a java.lang.Integer type.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
+ },
+ {
"name": "camel.component.vertx-kafka.sasl-login-refresh-buffer-seconds",
"type": "java.lang.Short",
"description": "The amount of buffer time before credential expiration to maintain when refreshing a credential, in seconds. If a refresh would otherwise occur closer to expiration than the number of buffer seconds then the refresh will be moved up to maintain as much of the buffer time as possible. Legal values are between 0 and 3600 (1 hour); a default value of 300 (5 minutes) is used if no value is specified. This value and sasl.login.refresh.min.period.seconds are both ignored [...]
@@ -501,6 +513,20 @@
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
},
{
+ "name": "camel.component.vertx-kafka.sasl-login-retry-backoff-max-ms",
+ "type": "java.lang.Long",
+ "description": "The (optional) value in milliseconds for the maximum wait between login attempts to the external authentication provider. Login uses an exponential backoff algorithm with an initial wait based on the sasl.login.retry.backoff.ms setting and will double in wait length between attempts up to a maximum wait length specified by the sasl.login.retry.backoff.max.ms setting. Currently applies only to OAUTHBEARER. The option is a long type.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": 10000
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-login-retry-backoff-ms",
+ "type": "java.lang.Long",
+ "description": "The (optional) value in milliseconds for the initial wait between login attempts to the external authentication provider. Login uses an exponential backoff algorithm with an initial wait based on the sasl.login.retry.backoff.ms setting and will double in wait length between attempts up to a maximum wait length specified by the sasl.login.retry.backoff.max.ms setting. Currently applies only to OAUTHBEARER. The option is a long type.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": 100
+ },
+ {
"name": "camel.component.vertx-kafka.sasl-mechanism",
"type": "java.lang.String",
"description": "SASL mechanism used for client connections. This may be any mechanism for which a security provider is available. GSSAPI is the default mechanism.",
@@ -508,6 +534,72 @@
"defaultValue": "GSSAPI"
},
{
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-clock-skew-seconds",
+ "type": "java.lang.Integer",
+ "description": "The (optional) value in seconds to allow for differences between the time of the OAuth\/OIDC identity provider and the broker.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": 30
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-expected-audience",
+ "type": "java.lang.String",
+ "description": "The (optional) comma-delimited setting for the broker to use to verify that the JWT was issued for one of the expected audiences. The JWT will be inspected for the standard OAuth aud claim and if this value is set, the broker will match the value from JWT's aud claim to see if there is an exact match. If there is no match, the broker will reject the JWT and authentication will fail.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-expected-issuer",
+ "type": "java.lang.String",
+ "description": "The (optional) setting for the broker to use to verify that the JWT was created by the expected issuer. The JWT will be inspected for the standard OAuth iss claim and if this value is set, the broker will match it exactly against what is in the JWT's iss claim. If there is no match, the broker will reject the JWT and authentication will fail.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-jwks-endpoint-refresh-ms",
+ "type": "java.lang.Long",
+ "description": "The (optional) value in milliseconds for the broker to wait between refreshing its JWKS (JSON Web Key Set) cache that contains the keys to verify the signature of the JWT. The option is a long type.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": 3600000
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-jwks-endpoint-retry-backoff-max-ms",
+ "type": "java.lang.Long",
+ "description": "The (optional) value in milliseconds for the maximum wait between attempts to retrieve the JWKS (JSON Web Key Set) from the external authentication provider. JWKS retrieval uses an exponential backoff algorithm with an initial wait based on the sasl.oauthbearer.jwks.endpoint.retry.backoff.ms setting and will double in wait length between attempts up to a maximum wait length specified by the sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms setting. The option is a [...]
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": 10000
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-jwks-endpoint-retry-backoff-ms",
+ "type": "java.lang.Long",
+ "description": "The (optional) value in milliseconds for the initial wait between JWKS (JSON Web Key Set) retrieval attempts from the external authentication provider. JWKS retrieval uses an exponential backoff algorithm with an initial wait based on the sasl.oauthbearer.jwks.endpoint.retry.backoff.ms setting and will double in wait length between attempts up to a maximum wait length specified by the sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms setting. The option is a long type.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": 100
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-jwks-endpoint-url",
+ "type": "java.lang.String",
+ "description": "The OAuth\/OIDC provider URL from which the provider's JWKS (JSON Web Key Set) can be retrieved. The URL can be HTTP(S)-based or file-based. If the URL is HTTP(S)-based, the JWKS data will be retrieved from the OAuth\/OIDC provider via the configured URL on broker startup. All then-current keys will be cached on the broker for incoming requests. If an authentication request is received for a JWT that includes a kid header claim value that isn't yet in the cache, the [...]
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-scope-claim-name",
+ "type": "java.lang.String",
+ "description": "The OAuth claim for the scope is often named scope, but this (optional) setting can provide a different name to use for the scope included in the JWT payload's claims if the OAuth\/OIDC provider uses a different name for that claim.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": "scope"
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-sub-claim-name",
+ "type": "java.lang.String",
+ "description": "The OAuth claim for the subject is often named sub, but this (optional) setting can provide a different name to use for the subject included in the JWT payload's claims if the OAuth\/OIDC provider uses a different name for that claim.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
+ "defaultValue": "sub"
+ },
+ {
+ "name": "camel.component.vertx-kafka.sasl-oauthbearer-token-endpoint-url",
+ "type": "java.lang.String",
+ "description": "The URL for the OAuth\/OIDC identity provider. If the URL is HTTP(S)-based, it is the issuer's token endpoint URL to which requests will be made to login based on the configuration in sasl.jaas.config. If the URL is file-based, it specifies a file containing an access token (in JWT serialized form) issued by the OAuth\/OIDC identity provider to use for authorization.",
+ "sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration"
+ },
+ {
"name": "camel.component.vertx-kafka.security-protocol",
"type": "java.lang.String",
"description": "Protocol used to communicate with brokers. Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.",
@@ -544,7 +636,7 @@
"type": "java.lang.Integer",
"description": "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.min.session.timeout.ms and gro [...]
"sourceType": "org.apache.camel.component.vertx.kafka.springboot.VertxKafkaComponentConfiguration",
- "defaultValue": 10000
+ "defaultValue": 45000
},
{
"name": "camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms",
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 9ac4f10..841d591 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
@@ -72,9 +72,7 @@ public class VertxKafkaComponentConfiguration
* hostname again (both the JVM and the OS cache DNS name lookups, however).
* If set to resolve_canonical_bootstrap_servers_only, resolve each
* bootstrap address into a list of canonical names. After the bootstrap
- * phase, this behaves the same as use_all_dns_ips. If set to default
- * (deprecated), attempt to connect to the first IP address returned by the
- * lookup, even if the lookup returns multiple IP addresses.
+ * phase, this behaves the same as use_all_dns_ips.
*/
private String clientDnsLookup = "use_all_dns_ips";
/**
@@ -386,8 +384,8 @@ public class VertxKafkaComponentConfiguration
* partition assignment strategies that the client will use to distribute
* partition ownership amongst consumer instances when group management is
* used. Available options
- * are:org.apache.kafka.clients.consumer.RangeAssignor: The default
- * assignor, which works on a per-topic
+ * are:org.apache.kafka.clients.consumer.RangeAssignor: Assigns partitions
+ * on a per-topic
* basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns
* partitions to consumers in a round-robin
* fashion.org.apache.kafka.clients.consumer.StickyAssignor: Guarantees an
@@ -395,11 +393,14 @@ public class VertxKafkaComponentConfiguration
* partition assignments as
* possible.org.apache.kafka.clients.consumer.CooperativeStickyAssignor:
* Follows the same StickyAssignor logic, but allows for cooperative
- * rebalancing.Implementing the
- * org.apache.kafka.clients.consumer.ConsumerPartitionAssignor interface
+ * rebalancing.The default assignor is RangeAssignor,
+ * CooperativeStickyAssignor, which will use the RangeAssignor by default,
+ * but allows upgrading to the CooperativeStickyAssignor with just a single
+ * rolling bounce that removes the RangeAssignor from the list.Implementing
+ * the org.apache.kafka.clients.consumer.ConsumerPartitionAssignor interface
* allows you to plug in a custom assignment strategy.
*/
- private String partitionAssignmentStrategy = "org.apache.kafka.clients.consumer.RangeAssignor";
+ private String partitionAssignmentStrategy = "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor";
/**
* Set if KafkaConsumer will read from a particular offset on startup. This
* config will take precedence over seekTo config
@@ -420,7 +421,7 @@ public class VertxKafkaComponentConfiguration
* configuration by group.min.session.timeout.ms and
* group.max.session.timeout.ms. The option is a int type.
*/
- private Integer sessionTimeoutMs = 10000;
+ private Integer sessionTimeoutMs = 45000;
/**
* Deserializer class for value that implements the
* org.apache.kafka.common.serialization.Deserializer interface.
@@ -457,7 +458,7 @@ public class VertxKafkaComponentConfiguration
* remains alive. This is the strongest available guarantee. This is
* equivalent to the acks=-1 setting.
*/
- private String acks = "1";
+ private String acks = "all";
/**
* The producer will attempt to batch records together into fewer requests
* whenever multiple records are being sent to the same partition. This
@@ -469,7 +470,12 @@ public class VertxKafkaComponentConfiguration
* throughput (a batch size of zero will disable batching entirely). A very
* large batch size may use memory a bit more wastefully as we will always
* allocate a buffer of the specified batch size in anticipation of
- * additional records.
+ * additional records.Note: This setting gives the upper bound of the batch
+ * size to be sent. If we have fewer than this many bytes accumulated for
+ * this partition, we will 'linger' for the linger.ms time waiting for more
+ * records to show up. This linger.ms setting defaults to 0, which means
+ * we'll immediately send out a record even the accumulated batch size is
+ * under this batch.size setting.
*/
private Integer batchSize = 16384;
/**
@@ -509,12 +515,13 @@ public class VertxKafkaComponentConfiguration
* each message is written in the stream. If 'false', producer retries due
* to broker failures, etc., may write duplicates of the retried message in
* the stream. Note that enabling idempotence requires
- * max.in.flight.requests.per.connection to be less than or equal to 5,
- * retries to be greater than 0 and acks must be 'all'. If these values are
- * not explicitly set by the user, suitable values will be chosen. If
+ * max.in.flight.requests.per.connection to be less than or equal to 5 (with
+ * message ordering preserved for any allowable value), retries to be
+ * greater than 0, and acks must be 'all'. If these values are not
+ * explicitly set by the user, suitable values will be chosen. If
* incompatible values are set, a ConfigException will be thrown.
*/
- private Boolean enableIdempotence = false;
+ private Boolean enableIdempotence = true;
/**
* Serializer class for key that implements the
* org.apache.kafka.common.serialization.Serializer interface.
@@ -538,7 +545,7 @@ public class VertxKafkaComponentConfiguration
* 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 record the producer will wait for up to the
+ * immediately sending out a record, the producer will wait for up to the
* given delay to allow other records to be sent so that the sends can be
* batched together. This can be thought of as analogous to Nagle's
* algorithm in TCP. This setting gives the upper bound on the delay for
@@ -567,9 +574,10 @@ public class VertxKafkaComponentConfiguration
private Long maxBlockMs = 60000L;
/**
* 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).
+ * single connection before blocking. Note that if this config is set to be
+ * greater than 1 and enable.idempotence is set to false, there is a risk of
+ * message re-ordering after a failed send due to retries (i.e., if retries
+ * are enabled).
*/
private Integer maxInFlightRequestsPerConnection = 5;
/**
@@ -590,8 +598,25 @@ public class VertxKafkaComponentConfiguration
*/
private Long metadataMaxIdleMs = 300000L;
/**
- * Partitioner class that implements the
- * org.apache.kafka.clients.producer.Partitioner interface.
+ * A class to use to determine which partition to be send to when produce
+ * the records. Available options
+ * are:org.apache.kafka.clients.producer.internals.DefaultPartitioner: The
+ * default partitioner. This strategy will try sticking to a partition until
+ * the batch is full, or linger.ms is up. It works with the strategy:If no
+ * partition is specified but a key is present, choose a partition based on
+ * a hash of the keyIf no partition or key is present, choose the sticky
+ * partition that changes when the batch is full, or linger.ms is
+ * up.org.apache.kafka.clients.producer.RoundRobinPartitioner: This
+ * partitioning strategy is that each record in a series of consecutive
+ * records will be sent to a different partition(no matter if the 'key' is
+ * provided or not), until we run out of partitions and start over again.
+ * Note: There's a known issue that will cause uneven distribution when new
+ * batch is created. Please check KAFKA-9965 for more
+ * detail.org.apache.kafka.clients.producer.UniformStickyPartitioner: This
+ * partitioning strategy will try sticking to a partition(no matter if the
+ * 'key' is provided or not) until the batch is full, or linger.ms is
+ * up.Implementing the org.apache.kafka.clients.producer.Partitioner
+ * interface allows you to plug in a custom partitioner.
*/
private String partitionerClass = "org.apache.kafka.clients.producer.internals.DefaultPartitioner";
/**
@@ -719,6 +744,18 @@ public class VertxKafkaComponentConfiguration
*/
private String saslLoginClass;
/**
+ * The (optional) value in milliseconds for the external authentication
+ * provider connection timeout. Currently applies only to OAUTHBEARER. The
+ * option is a java.lang.Integer type.
+ */
+ private Integer saslLoginConnectTimeoutMs;
+ /**
+ * The (optional) value in milliseconds for the external authentication
+ * provider read timeout. Currently applies only to OAUTHBEARER. The option
+ * is a java.lang.Integer type.
+ */
+ private Integer saslLoginReadTimeoutMs;
+ /**
* The amount of buffer time before credential expiration to maintain when
* refreshing a credential, in seconds. If a refresh would otherwise occur
* closer to expiration than the number of buffer seconds then the refresh
@@ -755,11 +792,121 @@ public class VertxKafkaComponentConfiguration
*/
private Double saslLoginRefreshWindowJitter;
/**
+ * The (optional) value in milliseconds for the maximum wait between login
+ * attempts to the external authentication provider. Login uses an
+ * exponential backoff algorithm with an initial wait based on the
+ * sasl.login.retry.backoff.ms setting and will double in wait length
+ * between attempts up to a maximum wait length specified by the
+ * sasl.login.retry.backoff.max.ms setting. Currently applies only to
+ * OAUTHBEARER. The option is a long type.
+ */
+ private Long saslLoginRetryBackoffMaxMs = 10000L;
+ /**
+ * The (optional) value in milliseconds for the initial wait between login
+ * attempts to the external authentication provider. Login uses an
+ * exponential backoff algorithm with an initial wait based on the
+ * sasl.login.retry.backoff.ms setting and will double in wait length
+ * between attempts up to a maximum wait length specified by the
+ * sasl.login.retry.backoff.max.ms setting. Currently applies only to
+ * OAUTHBEARER. The option is a long type.
+ */
+ private Long saslLoginRetryBackoffMs = 100L;
+ /**
* SASL mechanism used for client connections. This may be any mechanism for
* which a security provider is available. GSSAPI is the default mechanism.
*/
private String saslMechanism = "GSSAPI";
/**
+ * The (optional) value in seconds to allow for differences between the time
+ * of the OAuth/OIDC identity provider and the broker.
+ */
+ private Integer saslOauthbearerClockSkewSeconds = 30;
+ /**
+ * The (optional) comma-delimited setting for the broker to use to verify
+ * that the JWT was issued for one of the expected audiences. The JWT will
+ * be inspected for the standard OAuth aud claim and if this value is set,
+ * the broker will match the value from JWT's aud claim to see if there is
+ * an exact match. If there is no match, the broker will reject the JWT and
+ * authentication will fail.
+ */
+ private String saslOauthbearerExpectedAudience;
+ /**
+ * The (optional) setting for the broker to use to verify that the JWT was
+ * created by the expected issuer. The JWT will be inspected for the
+ * standard OAuth iss claim and if this value is set, the broker will match
+ * it exactly against what is in the JWT's iss claim. If there is no match,
+ * the broker will reject the JWT and authentication will fail.
+ */
+ private String saslOauthbearerExpectedIssuer;
+ /**
+ * The (optional) value in milliseconds for the broker to wait between
+ * refreshing its JWKS (JSON Web Key Set) cache that contains the keys to
+ * verify the signature of the JWT. The option is a long type.
+ */
+ private Long saslOauthbearerJwksEndpointRefreshMs = 3600000L;
+ /**
+ * The (optional) value in milliseconds for the maximum wait between
+ * attempts to retrieve the JWKS (JSON Web Key Set) from the external
+ * authentication provider. JWKS retrieval uses an exponential backoff
+ * algorithm with an initial wait based on the
+ * sasl.oauthbearer.jwks.endpoint.retry.backoff.ms setting and will double
+ * in wait length between attempts up to a maximum wait length specified by
+ * the sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms setting. The
+ * option is a long type.
+ */
+ private Long saslOauthbearerJwksEndpointRetryBackoffMaxMs = 10000L;
+ /**
+ * The (optional) value in milliseconds for the initial wait between JWKS
+ * (JSON Web Key Set) retrieval attempts from the external authentication
+ * provider. JWKS retrieval uses an exponential backoff algorithm with an
+ * initial wait based on the sasl.oauthbearer.jwks.endpoint.retry.backoff.ms
+ * setting and will double in wait length between attempts up to a maximum
+ * wait length specified by the
+ * sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms setting. The option
+ * is a long type.
+ */
+ private Long saslOauthbearerJwksEndpointRetryBackoffMs = 100L;
+ /**
+ * The OAuth/OIDC provider URL from which the provider's JWKS (JSON Web Key
+ * Set) can be retrieved. The URL can be HTTP(S)-based or file-based. If the
+ * URL is HTTP(S)-based, the JWKS data will be retrieved from the OAuth/OIDC
+ * provider via the configured URL on broker startup. All then-current keys
+ * will be cached on the broker for incoming requests. If an authentication
+ * request is received for a JWT that includes a kid header claim value that
+ * isn't yet in the cache, the JWKS endpoint will be queried again on
+ * demand. However, the broker polls the URL every
+ * sasl.oauthbearer.jwks.endpoint.refresh.ms milliseconds to refresh the
+ * cache with any forthcoming keys before any JWT requests that include them
+ * are received. If the URL is file-based, the broker will load the JWKS
+ * file from a configured location on startup. In the event that the JWT
+ * includes a kid header value that isn't in the JWKS file, the broker will
+ * reject the JWT and authentication will fail.
+ */
+ private String saslOauthbearerJwksEndpointUrl;
+ /**
+ * The OAuth claim for the scope is often named scope, but this (optional)
+ * setting can provide a different name to use for the scope included in the
+ * JWT payload's claims if the OAuth/OIDC provider uses a different name for
+ * that claim.
+ */
+ private String saslOauthbearerScopeClaimName = "scope";
+ /**
+ * The OAuth claim for the subject is often named sub, but this (optional)
+ * setting can provide a different name to use for the subject included in
+ * the JWT payload's claims if the OAuth/OIDC provider uses a different name
+ * for that claim.
+ */
+ private String saslOauthbearerSubClaimName = "sub";
+ /**
+ * The URL for the OAuth/OIDC identity provider. If the URL is
+ * HTTP(S)-based, it is the issuer's token endpoint URL to which requests
+ * will be made to login based on the configuration in sasl.jaas.config. If
+ * the URL is file-based, it specifies a file containing an access token (in
+ * JWT serialized form) issued by the OAuth/OIDC identity provider to use
+ * for authorization.
+ */
+ private String saslOauthbearerTokenEndpointUrl;
+ /**
* Protocol used to communicate with brokers. Valid values are: PLAINTEXT,
* SSL, SASL_PLAINTEXT, SASL_SSL.
*/
@@ -1538,6 +1685,22 @@ public class VertxKafkaComponentConfiguration
this.saslLoginClass = saslLoginClass;
}
+ public Integer getSaslLoginConnectTimeoutMs() {
+ return saslLoginConnectTimeoutMs;
+ }
+
+ public void setSaslLoginConnectTimeoutMs(Integer saslLoginConnectTimeoutMs) {
+ this.saslLoginConnectTimeoutMs = saslLoginConnectTimeoutMs;
+ }
+
+ public Integer getSaslLoginReadTimeoutMs() {
+ return saslLoginReadTimeoutMs;
+ }
+
+ public void setSaslLoginReadTimeoutMs(Integer saslLoginReadTimeoutMs) {
+ this.saslLoginReadTimeoutMs = saslLoginReadTimeoutMs;
+ }
+
public Short getSaslLoginRefreshBufferSeconds() {
return saslLoginRefreshBufferSeconds;
}
@@ -1574,6 +1737,22 @@ public class VertxKafkaComponentConfiguration
this.saslLoginRefreshWindowJitter = saslLoginRefreshWindowJitter;
}
+ public Long getSaslLoginRetryBackoffMaxMs() {
+ return saslLoginRetryBackoffMaxMs;
+ }
+
+ public void setSaslLoginRetryBackoffMaxMs(Long saslLoginRetryBackoffMaxMs) {
+ this.saslLoginRetryBackoffMaxMs = saslLoginRetryBackoffMaxMs;
+ }
+
+ public Long getSaslLoginRetryBackoffMs() {
+ return saslLoginRetryBackoffMs;
+ }
+
+ public void setSaslLoginRetryBackoffMs(Long saslLoginRetryBackoffMs) {
+ this.saslLoginRetryBackoffMs = saslLoginRetryBackoffMs;
+ }
+
public String getSaslMechanism() {
return saslMechanism;
}
@@ -1582,6 +1761,96 @@ public class VertxKafkaComponentConfiguration
this.saslMechanism = saslMechanism;
}
+ public Integer getSaslOauthbearerClockSkewSeconds() {
+ return saslOauthbearerClockSkewSeconds;
+ }
+
+ public void setSaslOauthbearerClockSkewSeconds(
+ Integer saslOauthbearerClockSkewSeconds) {
+ this.saslOauthbearerClockSkewSeconds = saslOauthbearerClockSkewSeconds;
+ }
+
+ public String getSaslOauthbearerExpectedAudience() {
+ return saslOauthbearerExpectedAudience;
+ }
+
+ public void setSaslOauthbearerExpectedAudience(
+ String saslOauthbearerExpectedAudience) {
+ this.saslOauthbearerExpectedAudience = saslOauthbearerExpectedAudience;
+ }
+
+ public String getSaslOauthbearerExpectedIssuer() {
+ return saslOauthbearerExpectedIssuer;
+ }
+
+ public void setSaslOauthbearerExpectedIssuer(
+ String saslOauthbearerExpectedIssuer) {
+ this.saslOauthbearerExpectedIssuer = saslOauthbearerExpectedIssuer;
+ }
+
+ public Long getSaslOauthbearerJwksEndpointRefreshMs() {
+ return saslOauthbearerJwksEndpointRefreshMs;
+ }
+
+ public void setSaslOauthbearerJwksEndpointRefreshMs(
+ Long saslOauthbearerJwksEndpointRefreshMs) {
+ this.saslOauthbearerJwksEndpointRefreshMs = saslOauthbearerJwksEndpointRefreshMs;
+ }
+
+ public Long getSaslOauthbearerJwksEndpointRetryBackoffMaxMs() {
+ return saslOauthbearerJwksEndpointRetryBackoffMaxMs;
+ }
+
+ public void setSaslOauthbearerJwksEndpointRetryBackoffMaxMs(
+ Long saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
+ this.saslOauthbearerJwksEndpointRetryBackoffMaxMs = saslOauthbearerJwksEndpointRetryBackoffMaxMs;
+ }
+
+ public Long getSaslOauthbearerJwksEndpointRetryBackoffMs() {
+ return saslOauthbearerJwksEndpointRetryBackoffMs;
+ }
+
+ public void setSaslOauthbearerJwksEndpointRetryBackoffMs(
+ Long saslOauthbearerJwksEndpointRetryBackoffMs) {
+ this.saslOauthbearerJwksEndpointRetryBackoffMs = saslOauthbearerJwksEndpointRetryBackoffMs;
+ }
+
+ public String getSaslOauthbearerJwksEndpointUrl() {
+ return saslOauthbearerJwksEndpointUrl;
+ }
+
+ public void setSaslOauthbearerJwksEndpointUrl(
+ String saslOauthbearerJwksEndpointUrl) {
+ this.saslOauthbearerJwksEndpointUrl = saslOauthbearerJwksEndpointUrl;
+ }
+
+ public String getSaslOauthbearerScopeClaimName() {
+ return saslOauthbearerScopeClaimName;
+ }
+
+ public void setSaslOauthbearerScopeClaimName(
+ String saslOauthbearerScopeClaimName) {
+ this.saslOauthbearerScopeClaimName = saslOauthbearerScopeClaimName;
+ }
+
+ public String getSaslOauthbearerSubClaimName() {
+ return saslOauthbearerSubClaimName;
+ }
+
+ public void setSaslOauthbearerSubClaimName(
+ String saslOauthbearerSubClaimName) {
+ this.saslOauthbearerSubClaimName = saslOauthbearerSubClaimName;
+ }
+
+ public String getSaslOauthbearerTokenEndpointUrl() {
+ return saslOauthbearerTokenEndpointUrl;
+ }
+
+ public void setSaslOauthbearerTokenEndpointUrl(
+ String saslOauthbearerTokenEndpointUrl) {
+ this.saslOauthbearerTokenEndpointUrl = saslOauthbearerTokenEndpointUrl;
+ }
+
public String getSecurityProtocol() {
return securityProtocol;
}