You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/01/28 15:01:57 UTC
[camel] branch main created (now a41323c)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
at a41323c Typo
This branch includes the following new commits:
new 85df145e Fix CI test
new 3d07945 CAMEL-17284: upgrade Kafka clients to 3.1.0
new 33d327e Fixed RAT check
new 9b49b05 Fixed RAT check
new b111e3d Regen for commit cc6711777701ef5b8b2adb099b406b2e1d6df02d
new a41323c Typo
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel] 04/06: Fixed RAT check
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9b49b05d42d791262ca845358c8c425e4acbb0cd
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 28 15:13:31 2022 +0100
Fixed RAT check
---
pom.xml | 1 +
1 file changed, 1 insertion(+)
diff --git a/pom.xml b/pom.xml
index 92630c3..4f319c3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -353,6 +353,7 @@
<exclude>**/MySecondBarConfigurer.java</exclude>
<exclude>**/stockquote-response.xml</exclude>
<exclude>**/org.apache.camel.dsl.kotlin.KotlinDSL.classname</exclude>
+ <exclude>**/quarkus-pom.ftl</exclude>
<!-- Maven Wrapper -->
<exclude>.mvn/**/*</exclude>
</excludes>
[camel] 01/06: Fix CI test
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 85df145e1940d21015ba1c4eff6d0c12eacc5823
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 28 15:02:15 2022 +0100
Fix CI test
---
.../camel/impl/DefaultProducerTemplateNonBlockingAsyncTest.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateNonBlockingAsyncTest.java b/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateNonBlockingAsyncTest.java
index 6848aca..4181083 100644
--- a/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateNonBlockingAsyncTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateNonBlockingAsyncTest.java
@@ -39,6 +39,12 @@ public class DefaultProducerTemplateNonBlockingAsyncTest extends DefaultProducer
}
@Test
+ @Override
+ public void testSendAsyncProcessor() throws Exception {
+ // noop
+ }
+
+ @Test
public void testRunningInSameThread() throws ExecutionException, InterruptedException {
Thread originalThread = Thread.currentThread();
CompletableFuture<Exchange> future = template.asyncSend("direct:echo", e -> {
[camel] 03/06: Fixed RAT check
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 33d327ed3f3f683a6ae6e038fe81e0283573a1f7
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 28 15:11:23 2022 +0100
Fixed RAT check
---
.../META-INF/services/org/apache/camel/component/dynamic-router | 1 -
1 file changed, 1 deletion(-)
diff --git a/components/camel-dynamic-router/src/main/resources/META-INF/services/org/apache/camel/component/dynamic-router b/components/camel-dynamic-router/src/main/resources/META-INF/services/org/apache/camel/component/dynamic-router
deleted file mode 100644
index c2e800d..0000000
--- a/components/camel-dynamic-router/src/main/resources/META-INF/services/org/apache/camel/component/dynamic-router
+++ /dev/null
@@ -1 +0,0 @@
-class=org.apache.camel.dynamicrouter.main.DynamicRouterComponent
[camel] 06/06: Typo
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit a41323c4d17af14db2e3cdebfa986a252de2c0eb
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 28 15:53:40 2022 +0100
Typo
---
components/camel-attachments/src/main/docs/attachments.adoc | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-attachments/src/main/docs/attachments.adoc b/components/camel-attachments/src/main/docs/attachments.adoc
index 61b69bd..7439a78 100644
--- a/components/camel-attachments/src/main/docs/attachments.adoc
+++ b/components/camel-attachments/src/main/docs/attachments.adoc
@@ -10,7 +10,7 @@
The attachments component provides the `javax.attachments` API support for Apache Camel.
A few Camel component uses attachments such as mail and web-service components.
-The attachments component is include automatic when using these components.
+The attachments component is included automatic when using these components.
The attachments support is on Camel `Message` level, for example to get
the `javax.activation.DataHandler` instance of the attachment, you can do as shown below:
[camel] 02/06: CAMEL-17284: upgrade Kafka clients to 3.1.0
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3d079458eda8de580fdb8e5075ad8be10f09c4c2
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 28 15:03:32 2022 +0100
CAMEL-17284: upgrade Kafka clients to 3.1.0
---
.../camel/catalog/components/vertx-kafka.json | 64 ++++++----------------
1 file changed, 18 insertions(+), 46 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
index f8d1c56..aca8dd2 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
@@ -24,7 +24,7 @@
"componentProperties": {
"additionalProperties": { "kind": "property", "displayName": "Additional Properties", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "additionalProperties.", "multiValue": true, "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "descrip [...]
"bootstrapServers": { "kind": "property", "displayName": "Bootstrap Servers", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A list of host\/port pairs to use for establishing the initial connection to the Kafka c [...]
- "clientDnsLookup": { "kind": "property", "displayName": "Client Dns Lookup", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configurati [...]
+ "clientDnsLookup": { "kind": "property", "displayName": "Client Dns Lookup", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "default", "use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": " [...]
"clientId": { "kind": "property", "displayName": "Client Id", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "An id string to pass to the server when making requests. The purpose of this is to be able to track the [...]
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configurations" },
"connectionsMaxIdleMs": { "kind": "property", "displayName": "Connections Max Idle Ms", "group": "common", "label": "common", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "9m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Close idle connections after the number of milliseconds specified [...]
@@ -65,26 +65,26 @@
"maxPartitionFetchBytes": { "kind": "property", "displayName": "Max Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1048576, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum amount of data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "property", "displayName": "Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum delay between invocations of poll() when using consumer g [...]
"maxPollRecords": { "kind": "property", "displayName": "Max Poll Records", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 500, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of records returned in a single call to poll(). Note, that [...]
- "partitionAssignmentStrategy": { "kind": "property", "displayName": "Partition Assignment Strategy", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfi [...]
+ "partitionAssignmentStrategy": { "kind": "property", "displayName": "Partition Assignment Strategy", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "descripti [...]
"seekToOffset": { "kind": "property", "displayName": "Seek To Offset", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from a particular offset on startup. This config will take pr [...]
"seekToPosition": { "kind": "property", "displayName": "Seek To Position", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from beginning or end on [...]
- "sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "45s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect client failures when using Kafka's group man [...]
+ "sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect client failures when using Kafka's group man [...]
"valueDeserializer": { "kind": "property", "displayName": "Value Deserializer", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.common.serialization.StringDeserializer", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Deseri [...]
"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka Manual Commit Factory", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommitFactory", "deprecated": false, "autowired": true, "secret": false, "description": "Factory to use for creating org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances. This allows to plugin [...]
- "acks": { "kind": "property", "displayName": "Acks", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "all", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The number of acknowledgments the producer requires [...]
- "batchSize": { "kind": "property", "displayName": "Batch Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 16384, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer will attempt to batch records together into fewer requests whenever multip [...]
+ "acks": { "kind": "property", "displayName": "Acks", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The number of acknowledgments the producer requires t [...]
+ "batchSize": { "kind": "property", "displayName": "Batch Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 16384, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer will attempt to batch records together into fewer requests whenever multip [...]
"bufferMemory": { "kind": "property", "displayName": "Buffer Memory", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 33554432, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The total bytes of memory the producer can use to buffer records waiting to b [...]
"compressionType": { "kind": "property", "displayName": "Compression Type", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "none", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The compression type for all data generated by the producer. T [...]
"deliveryTimeoutMs": { "kind": "property", "displayName": "Delivery Timeout Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "An upper bound on the time to report success or failure after a call t [...]
- "enableIdempotence": { "kind": "property", "displayName": "Enable Idempotence", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "When set to 'true', the producer will ensure that exactly one copy o [...]
+ "enableIdempotence": { "kind": "property", "displayName": "Enable Idempotence", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "When set to 'true', the producer will ensure that exactly one copy [...]
"keySerializer": { "kind": "property", "displayName": "Key Serializer", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.common.serialization.StringSerializer", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Serializer class [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during star [...]
- "lingerMs": { "kind": "property", "displayName": "Linger Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer groups together any records that arrive in between request transmissions i [...]
+ "lingerMs": { "kind": "property", "displayName": "Linger Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer groups together any records that arrive in between request transmissions i [...]
"maxBlockMs": { "kind": "property", "displayName": "Max Block Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The configuration controls how long the KafkaProducer's send(), partitionsFor(), in [...]
- "maxInFlightRequestsPerConnection": { "kind": "property", "displayName": "Max In Flight Requests Per Connection", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 5, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of unacknowledged requ [...]
+ "maxInFlightRequestsPerConnection": { "kind": "property", "displayName": "Max In Flight Requests Per Connection", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 5, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of unacknowledged requ [...]
"maxRequestSize": { "kind": "property", "displayName": "Max Request Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1048576, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum size of a request in bytes. This setting will limit the number [...]
"metadataMaxIdleMs": { "kind": "property", "displayName": "Metadata Max Idle Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Controls how long the producer will cache metadata for a topic that' [...]
- "partitionerClass": { "kind": "property", "displayName": "Partitioner Class", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.producer.internals.DefaultPartitioner", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A [...]
+ "partitionerClass": { "kind": "property", "displayName": "Partitioner Class", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.producer.internals.DefaultPartitioner", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Pa [...]
"retries": { "kind": "property", "displayName": "Retries", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2147483647, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Setting a value greater than zero will cause the client to resend any record whose send [...]
"transactionalId": { "kind": "property", "displayName": "Transactional Id", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The TransactionalId to use for transactional delivery. This enables reliability semant [...]
"transactionTimeoutMs": { "kind": "property", "displayName": "Transaction Timeout Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum amount of time in ms that the transaction coordinato [...]
@@ -102,25 +102,11 @@
"saslKerberosTicketRenewWindowFactor": { "kind": "property", "displayName": "Sasl Kerberos Ticket Renew Window Factor", "group": "security", "label": "common,security", "required": false, "type": "number", "javaType": "double", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.8, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Login thread will sleep [...]
"saslLoginCallbackHandlerClass": { "kind": "property", "displayName": "Sasl Login Callback Handler Class", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The fully qualified name of a SASL login callbac [...]
"saslLoginClass": { "kind": "property", "displayName": "Sasl Login Class", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The fully qualified name of a class that implements the Login interface. For bro [...]
- "saslLoginConnectTimeoutMs": { "kind": "property", "displayName": "Sasl Login Connect Timeout Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for the external [...]
- "saslLoginReadTimeoutMs": { "kind": "property", "displayName": "Sasl Login Read Timeout Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for the external authe [...]
"saslLoginRefreshBufferSeconds": { "kind": "property", "displayName": "Sasl Login Refresh Buffer Seconds", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "short", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "300", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The amount of buffer time before cr [...]
"saslLoginRefreshMinPeriodSeconds": { "kind": "property", "displayName": "Sasl Login Refresh Min Period Seconds", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "short", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "60", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The desired minimum time for [...]
"saslLoginRefreshWindowFactor": { "kind": "property", "displayName": "Sasl Login Refresh Window Factor", "group": "security", "label": "common,security", "required": false, "type": "number", "javaType": "double", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.8, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Login refresh thread will sleep until t [...]
"saslLoginRefreshWindowJitter": { "kind": "property", "displayName": "Sasl Login Refresh Window Jitter", "group": "security", "label": "common,security", "required": false, "type": "number", "javaType": "double", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.05, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum amount of random jitter re [...]
- "saslLoginRetryBackoffMaxMs": { "kind": "property", "displayName": "Sasl Login Retry Backoff Max Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for [...]
- "saslLoginRetryBackoffMs": { "kind": "property", "displayName": "Sasl Login Retry Backoff Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for the [...]
"saslMechanism": { "kind": "property", "displayName": "Sasl Mechanism", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "GSSAPI", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "SASL mechanism used for client connections. This may be a [...]
- "saslOauthbearerClockSkewSeconds": { "kind": "property", "displayName": "Sasl Oauthbearer Clock Skew Seconds", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 30, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in seconds to a [...]
- "saslOauthbearerExpectedAudience": { "kind": "property", "displayName": "Sasl Oauthbearer Expected Audience", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) comma-delimited setting for th [...]
- "saslOauthbearerExpectedIssuer": { "kind": "property", "displayName": "Sasl Oauthbearer Expected Issuer", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) setting for the broker to use to v [...]
- "saslOauthbearerJwksEndpointRefreshMs": { "kind": "property", "displayName": "Sasl Oauthbearer Jwks Endpoint Refresh Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1h", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value [...]
- "saslOauthbearerJwksEndpointRetryBackoffMaxMs": { "kind": "property", "displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Max Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Th [...]
- "saslOauthbearerJwksEndpointRetryBackoffMs": { "kind": "property", "displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (op [...]
- "saslOauthbearerJwksEndpointUrl": { "kind": "property", "displayName": "Sasl Oauthbearer Jwks Endpoint Url", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The OAuth\/OIDC provider URL from which the pr [...]
- "saslOauthbearerScopeClaimName": { "kind": "property", "displayName": "Sasl Oauthbearer Scope Claim Name", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "scope", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The OAuth claim for the [...]
- "saslOauthbearerSubClaimName": { "kind": "property", "displayName": "Sasl Oauthbearer Sub Claim Name", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "sub", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The OAuth claim for the subje [...]
- "saslOauthbearerTokenEndpointUrl": { "kind": "property", "displayName": "Sasl Oauthbearer Token Endpoint Url", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The URL for the OAuth\/OIDC identity provide [...]
"securityProtocol": { "kind": "property", "displayName": "Security Protocol", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "PLAINTEXT", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Protocol used to communicate with brokers. Valid [...]
"securityProviders": { "kind": "property", "displayName": "Security Providers", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A list of configurable creator classes each returning a provider implementi [...]
"sslCipherSuites": { "kind": "property", "displayName": "Ssl Cipher Suites", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A list of cipher suites. This is a named combination of authentication, encryp [...]
@@ -147,7 +133,7 @@
"topic": { "kind": "path", "displayName": "Topic", "group": "common", "label": "common", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Name of the topic to use. On the consumer you can use comma to separate multiple topics. A pr [...]
"additionalProperties": { "kind": "parameter", "displayName": "Additional Properties", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "additionalProperties.", "multiValue": true, "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "descri [...]
"bootstrapServers": { "kind": "parameter", "displayName": "Bootstrap Servers", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A list of host\/port pairs to use for establishing the initial connection to the Kafka [...]
- "clientDnsLookup": { "kind": "parameter", "displayName": "Client Dns Lookup", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configurat [...]
+ "clientDnsLookup": { "kind": "parameter", "displayName": "Client Dns Lookup", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "default", "use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": [...]
"clientId": { "kind": "parameter", "displayName": "Client Id", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "An id string to pass to the server when making requests. The purpose of this is to be able to track the [...]
"connectionsMaxIdleMs": { "kind": "parameter", "displayName": "Connections Max Idle Ms", "group": "common", "label": "common", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "9m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Close idle connections after the number of milliseconds specified [...]
"headerFilterStrategy": { "kind": "parameter", "displayName": "Header Filter Strategy", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "To use a custom HeaderFilterStrategy to filter header [...]
@@ -187,27 +173,27 @@
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1048576, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum amount of data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum delay between invocations of poll() when using consumer [...]
"maxPollRecords": { "kind": "parameter", "displayName": "Max Poll Records", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 500, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of records returned in a single call to poll(). Note, that [...]
- "partitionAssignmentStrategy": { "kind": "parameter", "displayName": "Partition Assignment Strategy", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConf [...]
+ "partitionAssignmentStrategy": { "kind": "parameter", "displayName": "Partition Assignment Strategy", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "descript [...]
"seekToOffset": { "kind": "parameter", "displayName": "Seek To Offset", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from a particular offset on startup. This config will take p [...]
"seekToPosition": { "kind": "parameter", "displayName": "Seek To Position", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from beginning or end o [...]
- "sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "45s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect client failures when using Kafka's group ma [...]
+ "sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect client failures when using Kafka's group ma [...]
"valueDeserializer": { "kind": "parameter", "displayName": "Value Deserializer", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.common.serialization.StringDeserializer", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Deser [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "acks": { "kind": "parameter", "displayName": "Acks", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "all", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The number of acknowledgments the producer require [...]
- "batchSize": { "kind": "parameter", "displayName": "Batch Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 16384, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer will attempt to batch records together into fewer requests whenever multi [...]
+ "acks": { "kind": "parameter", "displayName": "Acks", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The number of acknowledgments the producer requires [...]
+ "batchSize": { "kind": "parameter", "displayName": "Batch Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 16384, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer will attempt to batch records together into fewer requests whenever multi [...]
"bufferMemory": { "kind": "parameter", "displayName": "Buffer Memory", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 33554432, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The total bytes of memory the producer can use to buffer records waiting to [...]
"compressionType": { "kind": "parameter", "displayName": "Compression Type", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "none", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The compression type for all data generated by the producer. [...]
"deliveryTimeoutMs": { "kind": "parameter", "displayName": "Delivery Timeout Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "An upper bound on the time to report success or failure after a call [...]
- "enableIdempotence": { "kind": "parameter", "displayName": "Enable Idempotence", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "When set to 'true', the producer will ensure that exactly one copy [...]
+ "enableIdempotence": { "kind": "parameter", "displayName": "Enable Idempotence", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "When set to 'true', the producer will ensure that exactly one copy [...]
"keySerializer": { "kind": "parameter", "displayName": "Key Serializer", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.common.serialization.StringSerializer", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Serializer clas [...]
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during sta [...]
- "lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer groups together any records that arrive in between request transmissions [...]
+ "lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The producer groups together any records that arrive in between request transmissions [...]
"maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The configuration controls how long the KafkaProducer's send(), partitionsFor(), i [...]
- "maxInFlightRequestsPerConnection": { "kind": "parameter", "displayName": "Max In Flight Requests Per Connection", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 5, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of unacknowledged req [...]
+ "maxInFlightRequestsPerConnection": { "kind": "parameter", "displayName": "Max In Flight Requests Per Connection", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 5, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of unacknowledged req [...]
"maxRequestSize": { "kind": "parameter", "displayName": "Max Request Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1048576, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum size of a request in bytes. This setting will limit the numbe [...]
"metadataMaxIdleMs": { "kind": "parameter", "displayName": "Metadata Max Idle Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Controls how long the producer will cache metadata for a topic that [...]
- "partitionerClass": { "kind": "parameter", "displayName": "Partitioner Class", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.producer.internals.DefaultPartitioner", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A [...]
+ "partitionerClass": { "kind": "parameter", "displayName": "Partitioner Class", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.producer.internals.DefaultPartitioner", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "P [...]
"retries": { "kind": "parameter", "displayName": "Retries", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2147483647, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Setting a value greater than zero will cause the client to resend any record whose sen [...]
"transactionalId": { "kind": "parameter", "displayName": "Transactional Id", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The TransactionalId to use for transactional delivery. This enables reliability seman [...]
"transactionTimeoutMs": { "kind": "parameter", "displayName": "Transaction Timeout Ms", "group": "producer", "label": "producer", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1m", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum amount of time in ms that the transaction coordinat [...]
@@ -221,25 +207,11 @@
"saslKerberosTicketRenewWindowFactor": { "kind": "parameter", "displayName": "Sasl Kerberos Ticket Renew Window Factor", "group": "security", "label": "common,security", "required": false, "type": "number", "javaType": "double", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.8, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Login thread will sleep [...]
"saslLoginCallbackHandlerClass": { "kind": "parameter", "displayName": "Sasl Login Callback Handler Class", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The fully qualified name of a SASL login callba [...]
"saslLoginClass": { "kind": "parameter", "displayName": "Sasl Login Class", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The fully qualified name of a class that implements the Login interface. For br [...]
- "saslLoginConnectTimeoutMs": { "kind": "parameter", "displayName": "Sasl Login Connect Timeout Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for the externa [...]
- "saslLoginReadTimeoutMs": { "kind": "parameter", "displayName": "Sasl Login Read Timeout Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for the external auth [...]
"saslLoginRefreshBufferSeconds": { "kind": "parameter", "displayName": "Sasl Login Refresh Buffer Seconds", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "short", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "300", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The amount of buffer time before c [...]
"saslLoginRefreshMinPeriodSeconds": { "kind": "parameter", "displayName": "Sasl Login Refresh Min Period Seconds", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "short", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "60", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The desired minimum time for [...]
"saslLoginRefreshWindowFactor": { "kind": "parameter", "displayName": "Sasl Login Refresh Window Factor", "group": "security", "label": "common,security", "required": false, "type": "number", "javaType": "double", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.8, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Login refresh thread will sleep until [...]
"saslLoginRefreshWindowJitter": { "kind": "parameter", "displayName": "Sasl Login Refresh Window Jitter", "group": "security", "label": "common,security", "required": false, "type": "number", "javaType": "double", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.05, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The maximum amount of random jitter r [...]
- "saslLoginRetryBackoffMaxMs": { "kind": "parameter", "displayName": "Sasl Login Retry Backoff Max Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds fo [...]
- "saslLoginRetryBackoffMs": { "kind": "parameter", "displayName": "Sasl Login Retry Backoff Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in milliseconds for the [...]
"saslMechanism": { "kind": "parameter", "displayName": "Sasl Mechanism", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "GSSAPI", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "SASL mechanism used for client connections. This may be [...]
- "saslOauthbearerClockSkewSeconds": { "kind": "parameter", "displayName": "Sasl Oauthbearer Clock Skew Seconds", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 30, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value in seconds to [...]
- "saslOauthbearerExpectedAudience": { "kind": "parameter", "displayName": "Sasl Oauthbearer Expected Audience", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) comma-delimited setting for t [...]
- "saslOauthbearerExpectedIssuer": { "kind": "parameter", "displayName": "Sasl Oauthbearer Expected Issuer", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) setting for the broker to use to [...]
- "saslOauthbearerJwksEndpointRefreshMs": { "kind": "parameter", "displayName": "Sasl Oauthbearer Jwks Endpoint Refresh Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1h", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (optional) value [...]
- "saslOauthbearerJwksEndpointRetryBackoffMaxMs": { "kind": "parameter", "displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Max Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "T [...]
- "saslOauthbearerJwksEndpointRetryBackoffMs": { "kind": "parameter", "displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Ms", "group": "security", "label": "common,security", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The (o [...]
- "saslOauthbearerJwksEndpointUrl": { "kind": "parameter", "displayName": "Sasl Oauthbearer Jwks Endpoint Url", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The OAuth\/OIDC provider URL from which the p [...]
- "saslOauthbearerScopeClaimName": { "kind": "parameter", "displayName": "Sasl Oauthbearer Scope Claim Name", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "scope", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The OAuth claim for th [...]
- "saslOauthbearerSubClaimName": { "kind": "parameter", "displayName": "Sasl Oauthbearer Sub Claim Name", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "sub", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The OAuth claim for the subj [...]
- "saslOauthbearerTokenEndpointUrl": { "kind": "parameter", "displayName": "Sasl Oauthbearer Token Endpoint Url", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "The URL for the OAuth\/OIDC identity provid [...]
"securityProtocol": { "kind": "parameter", "displayName": "Security Protocol", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "PLAINTEXT", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Protocol used to communicate with brokers. Vali [...]
"securityProviders": { "kind": "parameter", "displayName": "Security Providers", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A list of configurable creator classes each returning a provider implement [...]
"sslCipherSuites": { "kind": "parameter", "displayName": "Ssl Cipher Suites", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "A list of cipher suites. This is a named combination of authentication, encry [...]
[camel] 05/06: Regen for commit cc6711777701ef5b8b2adb099b406b2e1d6df02d
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b111e3d9197639345f144cbea96213c04aa3fa11
Author: davsclaus <da...@users.noreply.github.com>
AuthorDate: Fri Jan 28 14:49:31 2022 +0000
Regen for commit cc6711777701ef5b8b2adb099b406b2e1d6df02d
Signed-off-by: GitHub <no...@github.com>
---
.../dsl/VertxKafkaComponentBuilderFactory.java | 371 +----
.../dsl/VertxKafkaEndpointBuilderFactory.java | 1470 +-------------------
2 files changed, 74 insertions(+), 1767 deletions(-)
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
index 09cdcd0..7f804f6 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
@@ -107,7 +107,9 @@ public interface VertxKafkaComponentBuilderFactory {
* 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.
+ * 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.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -896,8 +898,8 @@ public interface VertxKafkaComponentBuilderFactory {
* 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
+ * 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.kafka.clients.consumer.StickyAssignor: Guarantees
@@ -905,18 +907,13 @@ public interface VertxKafkaComponentBuilderFactory {
* existing partition assignments as
* possible.org.apache.kafka.clients.consumer.CooperativeStickyAssignor:
* Follows the same StickyAssignor logic, but allows for cooperative
- * 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
+ * rebalancing.Implementing the
* org.apache.kafka.clients.consumer.ConsumerPartitionAssignor interface
* allows you to plug in a custom assignment strategy.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default:
- * org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor
+ * Default: org.apache.kafka.clients.consumer.RangeAssignor
* Group: consumer
*
* @param partitionAssignmentStrategy the value to set
@@ -971,7 +968,7 @@ public interface VertxKafkaComponentBuilderFactory {
*
* The option is a: <code>int</code> type.
*
- * Default: 45s
+ * Default: 10s
* Group: consumer
*
* @param sessionTimeoutMs the value to set
@@ -1043,7 +1040,7 @@ public interface VertxKafkaComponentBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default: all
+ * Default: 1
* Group: producer
*
* @param acks the value to set
@@ -1064,13 +1061,7 @@ public interface VertxKafkaComponentBuilderFactory {
* less common and may reduce 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.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.
+ * specified batch size in anticipation of additional records.
*
* The option is a: <code>int</code> type.
*
@@ -1157,15 +1148,14 @@ public interface VertxKafkaComponentBuilderFactory {
* 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 not
- * explicitly set by the user, suitable values will be chosen. If
- * incompatible values are set, a ConfigException will be thrown.
+ * 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 incompatible values are set, a ConfigException will be thrown.
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: producer
*
* @param enableIdempotence the value to set
@@ -1225,7 +1215,7 @@ public interface VertxKafkaComponentBuilderFactory {
* the number of requests even under moderate load. This setting
* accomplishes this by adding a small amount of artificial
* delay&amp;mdash;that is, rather than immediately sending out a
- * record, the producer will wait for up to the given delay to allow
+ * 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 batching: once we get
@@ -1276,10 +1266,9 @@ public interface VertxKafkaComponentBuilderFactory {
}
/**
* 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).
+ * 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).
*
* The option is a: <code>int</code> type.
*
@@ -1334,28 +1323,8 @@ public interface VertxKafkaComponentBuilderFactory {
return this;
}
/**
- * 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.
+ * Partitioner class that implements the
+ * org.apache.kafka.clients.producer.Partitioner interface.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1690,38 +1659,6 @@ public interface VertxKafkaComponentBuilderFactory {
return this;
}
/**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginConnectTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslLoginConnectTimeoutMs(
- java.lang.Integer saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslLoginReadTimeoutMs(
- java.lang.Integer saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
* 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
@@ -1807,50 +1744,6 @@ public interface VertxKafkaComponentBuilderFactory {
return this;
}
/**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslLoginRetryBackoffMaxMs(
- long saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslLoginRetryBackoffMs(
- long saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
* SASL mechanism used for client connections. This may be any mechanism
* for which a security provider is available. GSSAPI is the default
* mechanism.
@@ -1869,214 +1762,6 @@ public interface VertxKafkaComponentBuilderFactory {
return this;
}
/**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerClockSkewSeconds(
- int saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedAudience the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerExpectedAudience(
- java.lang.String saslOauthbearerExpectedAudience) {
- doSetProperty("saslOauthbearerExpectedAudience", saslOauthbearerExpectedAudience);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedIssuer the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerExpectedIssuer(
- java.lang.String saslOauthbearerExpectedIssuer) {
- doSetProperty("saslOauthbearerExpectedIssuer", saslOauthbearerExpectedIssuer);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerJwksEndpointRefreshMs(
- long saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- long saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- long saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerJwksEndpointUrl(
- java.lang.String saslOauthbearerJwksEndpointUrl) {
- doSetProperty("saslOauthbearerJwksEndpointUrl", saslOauthbearerJwksEndpointUrl);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: scope
- * Group: security
- *
- * @param saslOauthbearerScopeClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerScopeClaimName(
- java.lang.String saslOauthbearerScopeClaimName) {
- doSetProperty("saslOauthbearerScopeClaimName", saslOauthbearerScopeClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: sub
- * Group: security
- *
- * @param saslOauthbearerSubClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerSubClaimName(
- java.lang.String saslOauthbearerSubClaimName) {
- doSetProperty("saslOauthbearerSubClaimName", saslOauthbearerSubClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerTokenEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaComponentBuilder saslOauthbearerTokenEndpointUrl(
- java.lang.String saslOauthbearerTokenEndpointUrl) {
- doSetProperty("saslOauthbearerTokenEndpointUrl", saslOauthbearerTokenEndpointUrl);
- return this;
- }
- /**
* Protocol used to communicate with brokers. Valid values are:
* PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
*
@@ -2552,25 +2237,11 @@ public interface VertxKafkaComponentBuilderFactory {
case "saslKerberosTicketRenewWindowFactor": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslKerberosTicketRenewWindowFactor((double) value); return true;
case "saslLoginCallbackHandlerClass": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginCallbackHandlerClass((java.lang.String) value); return true;
case "saslLoginClass": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginClass((java.lang.String) value); return true;
- case "saslLoginConnectTimeoutMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginConnectTimeoutMs((java.lang.Integer) value); return true;
- case "saslLoginReadTimeoutMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginReadTimeoutMs((java.lang.Integer) value); return true;
case "saslLoginRefreshBufferSeconds": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginRefreshBufferSeconds((short) value); return true;
case "saslLoginRefreshMinPeriodSeconds": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginRefreshMinPeriodSeconds((short) value); return true;
case "saslLoginRefreshWindowFactor": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginRefreshWindowFactor((double) value); return true;
case "saslLoginRefreshWindowJitter": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginRefreshWindowJitter((double) value); return true;
- case "saslLoginRetryBackoffMaxMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginRetryBackoffMaxMs((long) value); return true;
- case "saslLoginRetryBackoffMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslLoginRetryBackoffMs((long) value); return true;
case "saslMechanism": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslMechanism((java.lang.String) value); return true;
- case "saslOauthbearerClockSkewSeconds": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerClockSkewSeconds((int) value); return true;
- case "saslOauthbearerExpectedAudience": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerExpectedAudience((java.lang.String) value); return true;
- case "saslOauthbearerExpectedIssuer": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerExpectedIssuer((java.lang.String) value); return true;
- case "saslOauthbearerJwksEndpointRefreshMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerJwksEndpointRefreshMs((long) value); return true;
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerJwksEndpointRetryBackoffMaxMs((long) value); return true;
- case "saslOauthbearerJwksEndpointRetryBackoffMs": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerJwksEndpointRetryBackoffMs((long) value); return true;
- case "saslOauthbearerJwksEndpointUrl": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerJwksEndpointUrl((java.lang.String) value); return true;
- case "saslOauthbearerScopeClaimName": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerScopeClaimName((java.lang.String) value); return true;
- case "saslOauthbearerSubClaimName": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerSubClaimName((java.lang.String) value); return true;
- case "saslOauthbearerTokenEndpointUrl": getOrCreateConfiguration((VertxKafkaComponent) component).setSaslOauthbearerTokenEndpointUrl((java.lang.String) value); return true;
case "securityProtocol": getOrCreateConfiguration((VertxKafkaComponent) component).setSecurityProtocol((java.lang.String) value); return true;
case "securityProviders": getOrCreateConfiguration((VertxKafkaComponent) component).setSecurityProviders((java.lang.String) value); return true;
case "sslCipherSuites": getOrCreateConfiguration((VertxKafkaComponent) component).setSslCipherSuites((java.lang.String) value); return true;
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
index 761abe5..efe024a 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
@@ -128,7 +128,9 @@ public interface VertxKafkaEndpointBuilderFactory {
* 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.
+ * 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.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1478,8 +1480,8 @@ public interface VertxKafkaEndpointBuilderFactory {
* 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
+ * 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.kafka.clients.consumer.StickyAssignor: Guarantees
@@ -1487,18 +1489,13 @@ public interface VertxKafkaEndpointBuilderFactory {
* existing partition assignments as
* possible.org.apache.kafka.clients.consumer.CooperativeStickyAssignor:
* Follows the same StickyAssignor logic, but allows for cooperative
- * 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
+ * rebalancing.Implementing the
* org.apache.kafka.clients.consumer.ConsumerPartitionAssignor interface
* allows you to plug in a custom assignment strategy.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default:
- * org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor
+ * Default: org.apache.kafka.clients.consumer.RangeAssignor
* Group: consumer
*
* @param partitionAssignmentStrategy the value to set
@@ -1569,7 +1566,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option is a: <code>int</code> type.
*
- * Default: 45s
+ * Default: 10s
* Group: consumer
*
* @param sessionTimeoutMs the value to set
@@ -1592,7 +1589,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option will be converted to a <code>int</code> type.
*
- * Default: 45s
+ * Default: 10s
* Group: consumer
*
* @param sessionTimeoutMs the value to set
@@ -1829,72 +1826,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginConnectTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginConnectTimeoutMs(
- Integer saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginConnectTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginConnectTimeoutMs(
- String saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginReadTimeoutMs(
- Integer saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginReadTimeoutMs(
- String saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
* 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
@@ -2069,94 +2000,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginRetryBackoffMaxMs(
- long saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginRetryBackoffMaxMs(
- String saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginRetryBackoffMs(
- long saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslLoginRetryBackoffMs(
- String saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
* SASL mechanism used for client connections. This may be any mechanism
* for which a security provider is available. GSSAPI is the default
* mechanism.
@@ -2175,295 +2018,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerClockSkewSeconds(
- int saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerClockSkewSeconds(
- String saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedAudience the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerExpectedAudience(
- String saslOauthbearerExpectedAudience) {
- doSetProperty("saslOauthbearerExpectedAudience", saslOauthbearerExpectedAudience);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedIssuer the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerExpectedIssuer(
- String saslOauthbearerExpectedIssuer) {
- doSetProperty("saslOauthbearerExpectedIssuer", saslOauthbearerExpectedIssuer);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointRefreshMs(
- long saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointRefreshMs(
- String saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- long saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- String saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- long saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- String saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerJwksEndpointUrl(
- String saslOauthbearerJwksEndpointUrl) {
- doSetProperty("saslOauthbearerJwksEndpointUrl", saslOauthbearerJwksEndpointUrl);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: scope
- * Group: security
- *
- * @param saslOauthbearerScopeClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerScopeClaimName(
- String saslOauthbearerScopeClaimName) {
- doSetProperty("saslOauthbearerScopeClaimName", saslOauthbearerScopeClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: sub
- * Group: security
- *
- * @param saslOauthbearerSubClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerSubClaimName(
- String saslOauthbearerSubClaimName) {
- doSetProperty("saslOauthbearerSubClaimName", saslOauthbearerSubClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerTokenEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointConsumerBuilder saslOauthbearerTokenEndpointUrl(
- String saslOauthbearerTokenEndpointUrl) {
- doSetProperty("saslOauthbearerTokenEndpointUrl", saslOauthbearerTokenEndpointUrl);
- return this;
- }
- /**
* Protocol used to communicate with brokers. Valid values are:
* PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
*
@@ -3008,7 +2562,9 @@ public interface VertxKafkaEndpointBuilderFactory {
* 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.
+ * 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.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -3626,7 +3182,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default: all
+ * Default: 1
* Group: producer
*
* @param acks the value to set
@@ -3647,13 +3203,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* less common and may reduce 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.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.
+ * specified batch size in anticipation of additional records.
*
* The option is a: <code>int</code> type.
*
@@ -3678,13 +3228,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* less common and may reduce 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.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.
+ * specified batch size in anticipation of additional records.
*
* The option will be converted to a <code>int</code> type.
*
@@ -3820,15 +3364,14 @@ public interface VertxKafkaEndpointBuilderFactory {
* 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 not
- * explicitly set by the user, suitable values will be chosen. If
- * incompatible values are set, a ConfigException will be thrown.
+ * 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 incompatible values are set, a ConfigException will be thrown.
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: producer
*
* @param enableIdempotence the value to set
@@ -3844,16 +3387,15 @@ public interface VertxKafkaEndpointBuilderFactory {
* 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 not
- * explicitly set by the user, suitable values will be chosen. If
- * incompatible values are set, a ConfigException will be thrown.
+ * 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 incompatible values are set, a ConfigException will be thrown.
*
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
+ * Default: false
* Group: producer
*
* @param enableIdempotence the value to set
@@ -3938,7 +3480,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* the number of requests even under moderate load. This setting
* accomplishes this by adding a small amount of artificial
* delay&amp;mdash;that is, rather than immediately sending out a
- * record, the producer will wait for up to the given delay to allow
+ * 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 batching: once we get
@@ -3971,7 +3513,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* the number of requests even under moderate load. This setting
* accomplishes this by adding a small amount of artificial
* delay&amp;mdash;that is, rather than immediately sending out a
- * record, the producer will wait for up to the given delay to allow
+ * 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 batching: once we get
@@ -4046,10 +3588,9 @@ public interface VertxKafkaEndpointBuilderFactory {
}
/**
* 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).
+ * 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).
*
* The option is a: <code>int</code> type.
*
@@ -4066,10 +3607,9 @@ public interface VertxKafkaEndpointBuilderFactory {
}
/**
* 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).
+ * 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).
*
* The option will be converted to a <code>int</code> type.
*
@@ -4165,28 +3705,8 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * 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.
+ * Partitioner class that implements the
+ * org.apache.kafka.clients.producer.Partitioner interface.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -4548,93 +4068,27 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
+ * 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 if their sum exceeds the remaining lifetime of a
+ * credential. Currently applies only to OAUTHBEARER.
*
- * The option is a: <code>java.lang.Integer</code> type.
+ * The option is a: <code>short</code> type.
*
+ * Default: 300
* Group: security
*
- * @param saslLoginConnectTimeoutMs the value to set
+ * @param saslLoginRefreshBufferSeconds the value to set
* @return the dsl builder
*/
- default VertxKafkaEndpointProducerBuilder saslLoginConnectTimeoutMs(
- Integer saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginConnectTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginConnectTimeoutMs(
- String saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginReadTimeoutMs(
- Integer saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginReadTimeoutMs(
- String saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
- * 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 if their sum exceeds the remaining lifetime of a
- * credential. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>short</code> type.
- *
- * Default: 300
- * Group: security
- *
- * @param saslLoginRefreshBufferSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginRefreshBufferSeconds(
- short saslLoginRefreshBufferSeconds) {
- doSetProperty("saslLoginRefreshBufferSeconds", saslLoginRefreshBufferSeconds);
+ default VertxKafkaEndpointProducerBuilder saslLoginRefreshBufferSeconds(
+ short saslLoginRefreshBufferSeconds) {
+ doSetProperty("saslLoginRefreshBufferSeconds", saslLoginRefreshBufferSeconds);
return this;
}
/**
@@ -4788,94 +4242,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginRetryBackoffMaxMs(
- long saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginRetryBackoffMaxMs(
- String saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginRetryBackoffMs(
- long saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslLoginRetryBackoffMs(
- String saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
* SASL mechanism used for client connections. This may be any mechanism
* for which a security provider is available. GSSAPI is the default
* mechanism.
@@ -4894,295 +4260,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerClockSkewSeconds(
- int saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerClockSkewSeconds(
- String saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedAudience the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerExpectedAudience(
- String saslOauthbearerExpectedAudience) {
- doSetProperty("saslOauthbearerExpectedAudience", saslOauthbearerExpectedAudience);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedIssuer the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerExpectedIssuer(
- String saslOauthbearerExpectedIssuer) {
- doSetProperty("saslOauthbearerExpectedIssuer", saslOauthbearerExpectedIssuer);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointRefreshMs(
- long saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointRefreshMs(
- String saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- long saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- String saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- long saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- String saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerJwksEndpointUrl(
- String saslOauthbearerJwksEndpointUrl) {
- doSetProperty("saslOauthbearerJwksEndpointUrl", saslOauthbearerJwksEndpointUrl);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: scope
- * Group: security
- *
- * @param saslOauthbearerScopeClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerScopeClaimName(
- String saslOauthbearerScopeClaimName) {
- doSetProperty("saslOauthbearerScopeClaimName", saslOauthbearerScopeClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: sub
- * Group: security
- *
- * @param saslOauthbearerSubClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerSubClaimName(
- String saslOauthbearerSubClaimName) {
- doSetProperty("saslOauthbearerSubClaimName", saslOauthbearerSubClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerTokenEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointProducerBuilder saslOauthbearerTokenEndpointUrl(
- String saslOauthbearerTokenEndpointUrl) {
- doSetProperty("saslOauthbearerTokenEndpointUrl", saslOauthbearerTokenEndpointUrl);
- return this;
- }
- /**
* Protocol used to communicate with brokers. Valid values are:
* PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
*
@@ -5657,7 +4734,9 @@ public interface VertxKafkaEndpointBuilderFactory {
* 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.
+ * 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.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -6450,72 +5529,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginConnectTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginConnectTimeoutMs(
- Integer saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginConnectTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginConnectTimeoutMs(
- String saslLoginConnectTimeoutMs) {
- doSetProperty("saslLoginConnectTimeoutMs", saslLoginConnectTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginReadTimeoutMs(
- Integer saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: security
- *
- * @param saslLoginReadTimeoutMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginReadTimeoutMs(
- String saslLoginReadTimeoutMs) {
- doSetProperty("saslLoginReadTimeoutMs", saslLoginReadTimeoutMs);
- return this;
- }
- /**
* 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
@@ -6690,94 +5703,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginRetryBackoffMaxMs(
- long saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslLoginRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginRetryBackoffMaxMs(
- String saslLoginRetryBackoffMaxMs) {
- doSetProperty("saslLoginRetryBackoffMaxMs", saslLoginRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginRetryBackoffMs(
- long saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslLoginRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslLoginRetryBackoffMs(
- String saslLoginRetryBackoffMs) {
- doSetProperty("saslLoginRetryBackoffMs", saslLoginRetryBackoffMs);
- return this;
- }
- /**
* SASL mechanism used for client connections. This may be any mechanism
* for which a security provider is available. GSSAPI is the default
* mechanism.
@@ -6795,295 +5720,6 @@ public interface VertxKafkaEndpointBuilderFactory {
return this;
}
/**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerClockSkewSeconds(
- int saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * The (optional) value in seconds to allow for differences between the
- * time of the OAuth/OIDC identity provider and the broker.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 30
- * Group: security
- *
- * @param saslOauthbearerClockSkewSeconds the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerClockSkewSeconds(
- String saslOauthbearerClockSkewSeconds) {
- doSetProperty("saslOauthbearerClockSkewSeconds", saslOauthbearerClockSkewSeconds);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedAudience the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerExpectedAudience(
- String saslOauthbearerExpectedAudience) {
- doSetProperty("saslOauthbearerExpectedAudience", saslOauthbearerExpectedAudience);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerExpectedIssuer the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerExpectedIssuer(
- String saslOauthbearerExpectedIssuer) {
- doSetProperty("saslOauthbearerExpectedIssuer", saslOauthbearerExpectedIssuer);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointRefreshMs(
- long saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 1h
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRefreshMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointRefreshMs(
- String saslOauthbearerJwksEndpointRefreshMs) {
- doSetProperty("saslOauthbearerJwksEndpointRefreshMs", saslOauthbearerJwksEndpointRefreshMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- long saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 10s
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMaxMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointRetryBackoffMaxMs(
- String saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMaxMs", saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- return this;
- }
- /**
- * 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: <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- long saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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 will be converted to a <code>long</code> type.
- *
- * Default: 100ms
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointRetryBackoffMs the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointRetryBackoffMs(
- String saslOauthbearerJwksEndpointRetryBackoffMs) {
- doSetProperty("saslOauthbearerJwksEndpointRetryBackoffMs", saslOauthbearerJwksEndpointRetryBackoffMs);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerJwksEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerJwksEndpointUrl(
- String saslOauthbearerJwksEndpointUrl) {
- doSetProperty("saslOauthbearerJwksEndpointUrl", saslOauthbearerJwksEndpointUrl);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: scope
- * Group: security
- *
- * @param saslOauthbearerScopeClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerScopeClaimName(
- String saslOauthbearerScopeClaimName) {
- doSetProperty("saslOauthbearerScopeClaimName", saslOauthbearerScopeClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: sub
- * Group: security
- *
- * @param saslOauthbearerSubClaimName the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerSubClaimName(
- String saslOauthbearerSubClaimName) {
- doSetProperty("saslOauthbearerSubClaimName", saslOauthbearerSubClaimName);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param saslOauthbearerTokenEndpointUrl the value to set
- * @return the dsl builder
- */
- default VertxKafkaEndpointBuilder saslOauthbearerTokenEndpointUrl(
- String saslOauthbearerTokenEndpointUrl) {
- doSetProperty("saslOauthbearerTokenEndpointUrl", saslOauthbearerTokenEndpointUrl);
- return this;
- }
- /**
* Protocol used to communicate with brokers. Valid values are:
* PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
*