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
The following commit(s) were added to refs/heads/main by this push:
new dc34e6a Regen for commit d007d0e1aba6927b26eb8fae409cb5d81728bda7
dc34e6a is described below
commit dc34e6a87cdde3a2fda7dcfabcddab82e481d294
Author: oscerd <osc...@users.noreply.github.com>
AuthorDate: Fri May 7 06:35:43 2021 +0000
Regen for commit d007d0e1aba6927b26eb8fae409cb5d81728bda7
Signed-off-by: GitHub <nore...@github.com>
---
.../camel/catalog/components/vertx-kafka.json | 20 ++++-----
.../camel/catalog/docs/vertx-kafka-component.adoc | 20 ++++-----
.../configuration/VertxKafkaConfiguration.java | 23 +++++-----
.../camel/component/vertx/kafka/vertx-kafka.json | 20 ++++-----
.../src/main/docs/vertx-kafka-component.adoc | 20 ++++-----
.../dsl/VertxKafkaComponentBuilderFactory.java | 28 +++++++++----
.../dsl/VertxKafkaEndpointBuilderFactory.java | 49 ++++++++++++++--------
.../modules/ROOT/pages/vertx-kafka-component.adoc | 20 ++++-----
8 files changed, 112 insertions(+), 88 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
index 4232783..41174b2 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json
@@ -42,7 +42,7 @@
"requestTimeoutMs": { "kind": "property", "displayName": "Request Timeout
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "30s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client will wait [...]
"retryBackoffMs": { "kind": "property", "displayName": "Retry Backoff Ms",
"group": "common", "label": "common", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to retry a failed request to a [...]
"sendBufferBytes": { "kind": "property", "displayName": "Send Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 131072, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the [...]
- "socketConnectionSetupTimeoutMaxMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2m7s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clien [...]
+ "socketConnectionSetupTimeoutMaxMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the client [...]
"socketConnectionSetupTimeoutMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
client will wait for [...]
"allowAutoCreateTopics": { "kind": "property", "displayName": "Allow Auto
Create Topics", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Allow automatic topic
creation on the broker when subscrib [...]
"allowManualCommit": { "kind": "property", "displayName": "Allow Manual
Commit", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Whether to allow doing
manual commits via org.apache.camel.compone [...]
@@ -60,12 +60,12 @@
"groupId": { "kind": "property", "displayName": "Group Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique string that
identifies the consumer group this consumer belongs to. This property is
required [...]
"groupInstanceId": { "kind": "property", "displayName": "Group Instance
Id", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique identifier of
the consumer instance provided by the end user. Only non-empty [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "3s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator w [...]
- "isolationLevel": { "kind": "property", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Co [...]
+ "isolationLevel": { "kind": "property", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Co [...]
"keyDeserializer": { "kind": "property", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deserializ [...]
"maxPartitionFetchBytes": { "kind": "property", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "property", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer g [...]
- "maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()." },
- "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
+ "maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
+ "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
"seekToOffset": { "kind": "property", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take pr [...]
"seekToPosition": { "kind": "property", "displayName": "Seek To Position",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end on [...]
"sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group man [...]
@@ -94,7 +94,7 @@
"vertxKafkaClientFactory": { "kind": "property", "displayName": "Vertx
Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory", "deprecated":
false, "autowired": true, "secret": false, "description": "Factory to use for
creating io.vertx.kafka.client.consumer.KafkaConsumer and
io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to
configure a cust [...]
"vertxOptions": { "kind": "property", "displayName": "Vertx Options",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "io.vertx.core.VertxOptions", "deprecated": false, "autowired":
false, "secret": false, "description": "To provide a custom set of vertx
options for configuring vertx" },
"saslClientCallbackHandlerClass": { "kind": "property", "displayName":
"Sasl Client Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL client call [...]
- "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS co [...]
+ "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS co [...]
"saslKerberosKinitCmd": { "kind": "property", "displayName": "Sasl
Kerberos Kinit Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Kerberos kinit command
path." },
"saslKerberosMinTimeBeforeRelogin": { "kind": "property", "displayName":
"Sasl Kerberos Min Time Before Relogin", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread sleep time
betwe [...]
"saslKerberosServiceName": { "kind": "property", "displayName": "Sasl
Kerberos Service Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be d [...]
@@ -150,7 +150,7 @@
"requestTimeoutMs": { "kind": "parameter", "displayName": "Request Timeout
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "30s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client will wait [...]
"retryBackoffMs": { "kind": "parameter", "displayName": "Retry Backoff
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to retry a failed request to a [...]
"sendBufferBytes": { "kind": "parameter", "displayName": "Send Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 131072, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the [...]
- "socketConnectionSetupTimeoutMaxMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2m7s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clie [...]
+ "socketConnectionSetupTimeoutMaxMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clien [...]
"socketConnectionSetupTimeoutMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
client will wait for [...]
"allowAutoCreateTopics": { "kind": "parameter", "displayName": "Allow Auto
Create Topics", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Allow automatic topic
creation on the broker when subscri [...]
"allowManualCommit": { "kind": "parameter", "displayName": "Allow Manual
Commit", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Whether to allow doing
manual commits via org.apache.camel.compon [...]
@@ -168,12 +168,12 @@
"groupId": { "kind": "parameter", "displayName": "Group Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique string that
identifies the consumer group this consumer belongs to. This property is
require [...]
"groupInstanceId": { "kind": "parameter", "displayName": "Group Instance
Id", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique identifier of
the consumer instance provided by the end user. Only non-empt [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "3s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator [...]
- "isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "C [...]
+ "isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "C [...]
"keyDeserializer": { "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deseriali [...]
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer [...]
- "maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()." },
- "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
+ "maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
+ "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
"seekToOffset": { "kind": "parameter", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take p [...]
"seekToPosition": { "kind": "parameter", "displayName": "Seek To
Position", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end o [...]
"sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group ma [...]
@@ -199,7 +199,7 @@
"transactionTimeoutMs": { "kind": "parameter", "displayName": "Transaction
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time in ms that the transaction coordinat [...]
"valueSerializer": { "kind": "parameter", "displayName": "Value
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Serializer [...]
"saslClientCallbackHandlerClass": { "kind": "parameter", "displayName":
"Sasl Client Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL client cal [...]
- "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas
Config", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS c [...]
+ "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas
Config", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS c [...]
"saslKerberosKinitCmd": { "kind": "parameter", "displayName": "Sasl
Kerberos Kinit Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Kerberos kinit command
path." },
"saslKerberosMinTimeBeforeRelogin": { "kind": "parameter", "displayName":
"Sasl Kerberos Min Time Before Relogin", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread sleep time
betw [...]
"saslKerberosServiceName": { "kind": "parameter", "displayName": "Sasl
Kerberos Service Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/vertx-kafka-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/vertx-kafka-component.adoc
index 6c86bf5..1b627da 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/vertx-kafka-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/vertx-kafka-component.adoc
@@ -99,7 +99,7 @@ with the following path and query parameters:
| *requestTimeoutMs* (common) | The configuration controls the maximum amount
of time the client will wait for the response of a request. If the response is
not received before the timeout elapses the client will resend the request if
necessary or fail the request if retries are exhausted. This should be larger
than replica.lag.time.max.ms (a broker configuration) to reduce the possibility
of message duplication due to unnecessary producer retries. | 30s | int
| *retryBackoffMs* (common) | The amount of time to wait before attempting to
retry a failed request to a given topic partition. This avoids repeatedly
sending requests in a tight loop under some failure scenarios. | 100ms | long
| *sendBufferBytes* (common) | The size of the TCP send buffer (SO_SNDBUF) to
use when sending data. If the value is -1, the OS default will be used. |
131072 | int
-| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 2m7s | long
+| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 30s | long
| *socketConnectionSetupTimeoutMs* (common) | The amount of time the client
will wait for the socket connection to be established. If the connection is not
built before the timeout elapses, clients will close the socket channel. | 10s
| long
| *allowAutoCreateTopics* (consumer) | Allow automatic topic creation on the
broker when subscribing to or assigning a topic. A topic being subscribed to
will be automatically created only if the broker allows for it using
auto.create.topics.enable broker configuration. This configuration must be set
to false when using brokers older than 0.11.0 | true | boolean
| *allowManualCommit* (consumer) | Whether to allow doing manual commits via
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit. If this
option is enabled then an instance of
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit is stored
on the Exchange message header, which allows end users to access this API and
perform manual offset commits via the Kafka consumer. Note: To take full
control of the offset committing, you may need to disable the Kafka C [...]
@@ -117,12 +117,12 @@ with the following path and query parameters:
| *groupId* (consumer) | A unique string that identifies the consumer group
this consumer belongs to. This property is required if the consumer uses either
the group management functionality by using subscribe(topic) or the Kafka-based
offset management strategy. | | String
| *groupInstanceId* (consumer) | A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are permitted. If set, the
consumer is treated as a static member, which means that only one instance with
this ID is allowed in the consumer group at any time. This can be used in
combination with a larger session timeout to avoid group rebalances caused by
transient unavailability (e.g. process restarts). If not set, the consumer will
join the group as a dynami [...]
| *heartbeatIntervalMs* (consumer) | The expected time between heartbeats to
the consumer coordinator when using Kafka's group management facilities.
Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group. The value
must be set lower than session.timeout.ms, but typically should be set no
higher than 1/3 of that value. It can be adjusted even lower to control the
expected time for normal rebalances. [...]
-| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted'
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, c [...]
+| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, co [...]
| *keyDeserializer* (consumer) | Deserializer class for key that implements
the org.apache.kafka.common.serialization.Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
| *maxPartitionFetchBytes* (consumer) | The maximum amount of data
per-partition the server will return. Records are fetched in batches by the
consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). See fetch.max.bytes f [...]
| *maxPollIntervalMs* (consumer) | The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amount of time that the consumer can be idle before fetching more records. If
poll() is not called before expiration of this timeout, then the consumer is
considered failed and the group will rebalance in order to reassign the
partitions to another member. For consumers using a non-null group.instance.id
which reach this timeout, parti [...]
-| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). | 500 | int
-| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used.In addition to the default class
specified below, you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round robin
assignments of partitions to consumers. Implementing the
org.apache.kafka.clients.con [...]
+| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). Note, that max.poll.records does not impact the
underlying fetching behavior. The consumer will cache the records from each
fetch request and returns them incrementally from each poll. | 500 | int
+| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used. Available options
are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor,
which works on a per-topic
basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions
to consumers in a round-r [...]
| *seekToOffset* (consumer) | Set if KafkaConsumer will read from a particular
offset on startup. This config will take precedence over seekTo config | | Long
| *seekToPosition* (consumer) | Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning end : read from end. There
are 2 enums and the value can be one of: beginning, end | | String
| *sessionTimeoutMs* (consumer) | The timeout used to detect client failures
when using Kafka's group management facility. The client sends periodic
heartbeats to indicate its liveness to the broker. If no heartbeats are
received by the broker before the expiration of this session timeout, then the
broker will remove this client from the group and initiate a rebalance. Note
that the value must be in the allowable range as configured in the broker
configuration by group.min.session.timeou [...]
@@ -148,7 +148,7 @@ with the following path and query parameters:
| *transactionTimeoutMs* (producer) | The maximum amount of time in ms that
the transaction coordinator will wait for a transaction status update from the
producer before proactively aborting the ongoing transaction.If this value is
larger than the transaction.max.timeout.ms setting in the broker, the request
will fail with a InvalidTxnTimeoutException error. | 1m | int
| *valueSerializer* (producer) | Serializer class for value that implements
the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
| *saslClientCallbackHandlerClass* (security) | The fully qualified name of a
SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: 'loginModuleClass
controlFlag (optionName=optionValue);'. For brokers, the config must be
prefixed with listener prefix and SASL mechanism name in lower-case. For
example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
+| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: loginModuleClass
controlFlag (optionName=optionValue);. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
| *saslKerberosKinitCmd* (security) | Kerberos kinit command path. |
/usr/bin/kinit | String
| *saslKerberosMinTimeBefore{zwsp}Relogin* (security) | Login thread sleep
time between refresh attempts. | 60000 | long
| *saslKerberosServiceName* (security) | The Kerberos principal name that
Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's
config. | | String
@@ -214,7 +214,7 @@ The Vert.x Kafka component supports 106 options, which are
listed below.
| *requestTimeoutMs* (common) | The configuration controls the maximum amount
of time the client will wait for the response of a request. If the response is
not received before the timeout elapses the client will resend the request if
necessary or fail the request if retries are exhausted. This should be larger
than replica.lag.time.max.ms (a broker configuration) to reduce the possibility
of message duplication due to unnecessary producer retries. | 30s | int
| *retryBackoffMs* (common) | The amount of time to wait before attempting to
retry a failed request to a given topic partition. This avoids repeatedly
sending requests in a tight loop under some failure scenarios. | 100ms | long
| *sendBufferBytes* (common) | The size of the TCP send buffer (SO_SNDBUF) to
use when sending data. If the value is -1, the OS default will be used. |
131072 | int
-| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 2m7s | long
+| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 30s | long
| *socketConnectionSetupTimeoutMs* (common) | The amount of time the client
will wait for the socket connection to be established. If the connection is not
built before the timeout elapses, clients will close the socket channel. | 10s
| long
| *allowAutoCreateTopics* (consumer) | Allow automatic topic creation on the
broker when subscribing to or assigning a topic. A topic being subscribed to
will be automatically created only if the broker allows for it using
auto.create.topics.enable broker configuration. This configuration must be set
to false when using brokers older than 0.11.0 | true | boolean
| *allowManualCommit* (consumer) | Whether to allow doing manual commits via
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit. If this
option is enabled then an instance of
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit is stored
on the Exchange message header, which allows end users to access this API and
perform manual offset commits via the Kafka consumer. Note: To take full
control of the offset committing, you may need to disable the Kafka C [...]
@@ -232,12 +232,12 @@ The Vert.x Kafka component supports 106 options, which
are listed below.
| *groupId* (consumer) | A unique string that identifies the consumer group
this consumer belongs to. This property is required if the consumer uses either
the group management functionality by using subscribe(topic) or the Kafka-based
offset management strategy. | | String
| *groupInstanceId* (consumer) | A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are permitted. If set, the
consumer is treated as a static member, which means that only one instance with
this ID is allowed in the consumer group at any time. This can be used in
combination with a larger session timeout to avoid group rebalances caused by
transient unavailability (e.g. process restarts). If not set, the consumer will
join the group as a dynami [...]
| *heartbeatIntervalMs* (consumer) | The expected time between heartbeats to
the consumer coordinator when using Kafka's group management facilities.
Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group. The value
must be set lower than session.timeout.ms, but typically should be set no
higher than 1/3 of that value. It can be adjusted even lower to control the
expected time for normal rebalances. [...]
-| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted'
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, c [...]
+| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, co [...]
| *keyDeserializer* (consumer) | Deserializer class for key that implements
the org.apache.kafka.common.serialization.Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
| *maxPartitionFetchBytes* (consumer) | The maximum amount of data
per-partition the server will return. Records are fetched in batches by the
consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). See fetch.max.bytes f [...]
| *maxPollIntervalMs* (consumer) | The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amount of time that the consumer can be idle before fetching more records. If
poll() is not called before expiration of this timeout, then the consumer is
considered failed and the group will rebalance in order to reassign the
partitions to another member. For consumers using a non-null group.instance.id
which reach this timeout, parti [...]
-| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). | 500 | int
-| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used.In addition to the default class
specified below, you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round robin
assignments of partitions to consumers. Implementing the
org.apache.kafka.clients.con [...]
+| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). Note, that max.poll.records does not impact the
underlying fetching behavior. The consumer will cache the records from each
fetch request and returns them incrementally from each poll. | 500 | int
+| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used. Available options
are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor,
which works on a per-topic
basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions
to consumers in a round-r [...]
| *seekToOffset* (consumer) | Set if KafkaConsumer will read from a particular
offset on startup. This config will take precedence over seekTo config | | Long
| *seekToPosition* (consumer) | Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning end : read from end. There
are 2 enums and the value can be one of: beginning, end | | String
| *sessionTimeoutMs* (consumer) | The timeout used to detect client failures
when using Kafka's group management facility. The client sends periodic
heartbeats to indicate its liveness to the broker. If no heartbeats are
received by the broker before the expiration of this session timeout, then the
broker will remove this client from the group and initiate a rebalance. Note
that the value must be in the allowable range as configured in the broker
configuration by group.min.session.timeou [...]
@@ -266,7 +266,7 @@ The Vert.x Kafka component supports 106 options, which are
listed below.
| *vertxKafkaClientFactory* (advanced) | *Autowired* Factory to use for
creating io.vertx.kafka.client.consumer.KafkaConsumer and
io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to
configure a custom factory to create custom KafkaConsumer and KafkaProducer
instances with logic that extends the vanilla VertX Kafka clients. | |
VertxKafkaClientFactory
| *vertxOptions* (advanced) | To provide a custom set of vertx options for
configuring vertx | | VertxOptions
| *saslClientCallbackHandlerClass* (security) | The fully qualified name of a
SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: 'loginModuleClass
controlFlag (optionName=optionValue);'. For brokers, the config must be
prefixed with listener prefix and SASL mechanism name in lower-case. For
example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
+| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: loginModuleClass
controlFlag (optionName=optionValue);. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
| *saslKerberosKinitCmd* (security) | Kerberos kinit command path. |
/usr/bin/kinit | String
| *saslKerberosMinTimeBefore{zwsp}Relogin* (security) | Login thread sleep
time between refresh attempts. | 60000 | long
| *saslKerberosServiceName* (security) | The Kerberos principal name that
Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's
config. | | String
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
index 8329473..013d544 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
@@ -70,8 +70,8 @@ public class VertxKafkaConfiguration
@UriParam(label = "common", defaultValue = "10s", javaType =
"java.time.Duration")
private long socketConnectionSetupTimeoutMs = 10000;
// socket.connection.setup.timeout.max.ms
- @UriParam(label = "common", defaultValue = "2m7s", javaType =
"java.time.Duration")
- private long socketConnectionSetupTimeoutMaxMs = 127000;
+ @UriParam(label = "common", defaultValue = "30s", javaType =
"java.time.Duration")
+ private long socketConnectionSetupTimeoutMaxMs = 30000;
// connections.max.idle.ms
@UriParam(label = "common", defaultValue = "9m", javaType =
"java.time.Duration")
private long connectionsMaxIdleMs = 540000;
@@ -1013,7 +1013,7 @@ public class VertxKafkaConfiguration
/**
* JAAS login context parameters for SASL connections in the format used by
* JAAS configuration files. JAAS configuration file format is described <a
- *
href="http://docs.oracle.com/javase/8/docs/technotes/guides/security/jgss/tutorials/LoginConfigFile.html";>here</a>.
The format for the value is: '<code>loginModuleClass controlFlag
(optionName=optionValue)*;</code>'. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required;
+ *
href="http://docs.oracle.com/javase/8/docs/technotes/guides/security/jgss/tutorials/LoginConfigFile.html";>here</a>.
The format for the value is: <code>loginModuleClass controlFlag
(optionName=optionValue)*;</code>. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required;
*/
public void setSaslJaasConfig(String saslJaasConfig) {
this.saslJaasConfig = saslJaasConfig;
@@ -1176,12 +1176,10 @@ public class VertxKafkaConfiguration
* A list of class names or class types, ordered by preference, of
supported
* partition assignment strategies that the client will use to distribute
* partition ownership amongst consumer instances when group management is
- * used.<p>In addition to the default class specified below, you can use
the
- * <code>org.apache.kafka.clients.consumer.RoundRobinAssignor</code>class
- * for round robin assignments of partitions to consumers.
- * </p><p>Implementing the
- * <code>org.apache.kafka.clients.consumer.ConsumerPartitionAssignor</code>
- * interface allows you to plug in a custom assignmentstrategy.
+ * used. Available options
+ *
are:<ul><li><code>org.apache.kafka.clients.consumer.RangeAssignor</code>:
+ * The default assignor, which works on a per-topic
+ *
basis.</li><li><code>org.apache.kafka.clients.consumer.RoundRobinAssignor</code>:
Assigns partitions to consumers in a round-robin
fashion.</li><li><code>org.apache.kafka.clients.consumer.StickyAssignor</code>:
Guarantees an assignment that is maximally balanced while preserving as many
existing partition assignments as
possible.</li><li><code>org.apache.kafka.clients.consumer.CooperativeStickyAssignor</code>:
Follows the same StickyAssignor logic, but allows for cooperative rebal [...]
*/
public void setPartitionAssignmentStrategy(
String partitionAssignmentStrategy) {
@@ -1369,7 +1367,10 @@ public class VertxKafkaConfiguration
}
/**
- * The maximum number of records returned in a single call to poll().
+ * The maximum number of records returned in a single call to poll(). Note,
+ * that <code>max.poll.records</code> does not impact the underlying
+ * fetching behavior. The consumer will cache the records from each fetch
+ * request and returns them incrementally from each poll.
*/
public void setMaxPollRecords(int maxPollRecords) {
this.maxPollRecords = maxPollRecords;
@@ -1417,7 +1418,7 @@ public class VertxKafkaConfiguration
* Controls how to read messages written transactionally. If set to
* <code>read_committed</code>, consumer.poll() will only return
* transactional messages which have been committed. If set to
- * <code>read_uncommitted</code>' (the default), consumer.poll() will
return
+ * <code>read_uncommitted</code> (the default), consumer.poll() will return
* all messages, even transactional messages which have been aborted.
* Non-transactional messages will be returned unconditionally in either
* mode. <p>Messages will always be returned in offset order. Hence, in
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
index 4232783..41174b2 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
@@ -42,7 +42,7 @@
"requestTimeoutMs": { "kind": "property", "displayName": "Request Timeout
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "30s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client will wait [...]
"retryBackoffMs": { "kind": "property", "displayName": "Retry Backoff Ms",
"group": "common", "label": "common", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to retry a failed request to a [...]
"sendBufferBytes": { "kind": "property", "displayName": "Send Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 131072, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the [...]
- "socketConnectionSetupTimeoutMaxMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2m7s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clien [...]
+ "socketConnectionSetupTimeoutMaxMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the client [...]
"socketConnectionSetupTimeoutMs": { "kind": "property", "displayName":
"Socket Connection Setup Timeout Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
client will wait for [...]
"allowAutoCreateTopics": { "kind": "property", "displayName": "Allow Auto
Create Topics", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Allow automatic topic
creation on the broker when subscrib [...]
"allowManualCommit": { "kind": "property", "displayName": "Allow Manual
Commit", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Whether to allow doing
manual commits via org.apache.camel.compone [...]
@@ -60,12 +60,12 @@
"groupId": { "kind": "property", "displayName": "Group Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique string that
identifies the consumer group this consumer belongs to. This property is
required [...]
"groupInstanceId": { "kind": "property", "displayName": "Group Instance
Id", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique identifier of
the consumer instance provided by the end user. Only non-empty [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "3s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator w [...]
- "isolationLevel": { "kind": "property", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Co [...]
+ "isolationLevel": { "kind": "property", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Co [...]
"keyDeserializer": { "kind": "property", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deserializ [...]
"maxPartitionFetchBytes": { "kind": "property", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "property", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer g [...]
- "maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()." },
- "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
+ "maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
+ "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
"seekToOffset": { "kind": "property", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take pr [...]
"seekToPosition": { "kind": "property", "displayName": "Seek To Position",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end on [...]
"sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group man [...]
@@ -94,7 +94,7 @@
"vertxKafkaClientFactory": { "kind": "property", "displayName": "Vertx
Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory", "deprecated":
false, "autowired": true, "secret": false, "description": "Factory to use for
creating io.vertx.kafka.client.consumer.KafkaConsumer and
io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to
configure a cust [...]
"vertxOptions": { "kind": "property", "displayName": "Vertx Options",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "io.vertx.core.VertxOptions", "deprecated": false, "autowired":
false, "secret": false, "description": "To provide a custom set of vertx
options for configuring vertx" },
"saslClientCallbackHandlerClass": { "kind": "property", "displayName":
"Sasl Client Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL client call [...]
- "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS co [...]
+ "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS co [...]
"saslKerberosKinitCmd": { "kind": "property", "displayName": "Sasl
Kerberos Kinit Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Kerberos kinit command
path." },
"saslKerberosMinTimeBeforeRelogin": { "kind": "property", "displayName":
"Sasl Kerberos Min Time Before Relogin", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread sleep time
betwe [...]
"saslKerberosServiceName": { "kind": "property", "displayName": "Sasl
Kerberos Service Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be d [...]
@@ -150,7 +150,7 @@
"requestTimeoutMs": { "kind": "parameter", "displayName": "Request Timeout
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "30s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls the maximum amount of time the client will wait [...]
"retryBackoffMs": { "kind": "parameter", "displayName": "Retry Backoff
Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to retry a failed request to a [...]
"sendBufferBytes": { "kind": "parameter", "displayName": "Send Buffer
Bytes", "group": "common", "label": "common", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 131072, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the [...]
- "socketConnectionSetupTimeoutMaxMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2m7s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clie [...]
+ "socketConnectionSetupTimeoutMaxMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Max Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time the clien [...]
"socketConnectionSetupTimeoutMs": { "kind": "parameter", "displayName":
"Socket Connection Setup Timeout Ms", "group": "common", "label": "common",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
client will wait for [...]
"allowAutoCreateTopics": { "kind": "parameter", "displayName": "Allow Auto
Create Topics", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Allow automatic topic
creation on the broker when subscri [...]
"allowManualCommit": { "kind": "parameter", "displayName": "Allow Manual
Commit", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Whether to allow doing
manual commits via org.apache.camel.compon [...]
@@ -168,12 +168,12 @@
"groupId": { "kind": "parameter", "displayName": "Group Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique string that
identifies the consumer group this consumer belongs to. This property is
require [...]
"groupInstanceId": { "kind": "parameter", "displayName": "Group Instance
Id", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A unique identifier of
the consumer instance provided by the end user. Only non-empt [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "3s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinator [...]
- "isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "C [...]
+ "isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "read_committed", "read_uncommitted"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "C [...]
"keyDeserializer": { "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deseriali [...]
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer [...]
- "maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()." },
- "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
+ "maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
+ "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
"seekToOffset": { "kind": "parameter", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take p [...]
"seekToPosition": { "kind": "parameter", "displayName": "Seek To
Position", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end o [...]
"sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group ma [...]
@@ -199,7 +199,7 @@
"transactionTimeoutMs": { "kind": "parameter", "displayName": "Transaction
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time in ms that the transaction coordinat [...]
"valueSerializer": { "kind": "parameter", "displayName": "Value
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Serializer [...]
"saslClientCallbackHandlerClass": { "kind": "parameter", "displayName":
"Sasl Client Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL client cal [...]
- "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas
Config", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS c [...]
+ "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas
Config", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "JAAS login context
parameters for SASL connections in the format used by JAAS c [...]
"saslKerberosKinitCmd": { "kind": "parameter", "displayName": "Sasl
Kerberos Kinit Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Kerberos kinit command
path." },
"saslKerberosMinTimeBeforeRelogin": { "kind": "parameter", "displayName":
"Sasl Kerberos Min Time Before Relogin", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread sleep time
betw [...]
"saslKerberosServiceName": { "kind": "parameter", "displayName": "Sasl
Kerberos Service Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be [...]
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
index 6c86bf5..1b627da 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
@@ -99,7 +99,7 @@ with the following path and query parameters:
| *requestTimeoutMs* (common) | The configuration controls the maximum amount
of time the client will wait for the response of a request. If the response is
not received before the timeout elapses the client will resend the request if
necessary or fail the request if retries are exhausted. This should be larger
than replica.lag.time.max.ms (a broker configuration) to reduce the possibility
of message duplication due to unnecessary producer retries. | 30s | int
| *retryBackoffMs* (common) | The amount of time to wait before attempting to
retry a failed request to a given topic partition. This avoids repeatedly
sending requests in a tight loop under some failure scenarios. | 100ms | long
| *sendBufferBytes* (common) | The size of the TCP send buffer (SO_SNDBUF) to
use when sending data. If the value is -1, the OS default will be used. |
131072 | int
-| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 2m7s | long
+| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 30s | long
| *socketConnectionSetupTimeoutMs* (common) | The amount of time the client
will wait for the socket connection to be established. If the connection is not
built before the timeout elapses, clients will close the socket channel. | 10s
| long
| *allowAutoCreateTopics* (consumer) | Allow automatic topic creation on the
broker when subscribing to or assigning a topic. A topic being subscribed to
will be automatically created only if the broker allows for it using
auto.create.topics.enable broker configuration. This configuration must be set
to false when using brokers older than 0.11.0 | true | boolean
| *allowManualCommit* (consumer) | Whether to allow doing manual commits via
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit. If this
option is enabled then an instance of
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit is stored
on the Exchange message header, which allows end users to access this API and
perform manual offset commits via the Kafka consumer. Note: To take full
control of the offset committing, you may need to disable the Kafka C [...]
@@ -117,12 +117,12 @@ with the following path and query parameters:
| *groupId* (consumer) | A unique string that identifies the consumer group
this consumer belongs to. This property is required if the consumer uses either
the group management functionality by using subscribe(topic) or the Kafka-based
offset management strategy. | | String
| *groupInstanceId* (consumer) | A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are permitted. If set, the
consumer is treated as a static member, which means that only one instance with
this ID is allowed in the consumer group at any time. This can be used in
combination with a larger session timeout to avoid group rebalances caused by
transient unavailability (e.g. process restarts). If not set, the consumer will
join the group as a dynami [...]
| *heartbeatIntervalMs* (consumer) | The expected time between heartbeats to
the consumer coordinator when using Kafka's group management facilities.
Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group. The value
must be set lower than session.timeout.ms, but typically should be set no
higher than 1/3 of that value. It can be adjusted even lower to control the
expected time for normal rebalances. [...]
-| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted'
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, c [...]
+| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, co [...]
| *keyDeserializer* (consumer) | Deserializer class for key that implements
the org.apache.kafka.common.serialization.Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
| *maxPartitionFetchBytes* (consumer) | The maximum amount of data
per-partition the server will return. Records are fetched in batches by the
consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). See fetch.max.bytes f [...]
| *maxPollIntervalMs* (consumer) | The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amount of time that the consumer can be idle before fetching more records. If
poll() is not called before expiration of this timeout, then the consumer is
considered failed and the group will rebalance in order to reassign the
partitions to another member. For consumers using a non-null group.instance.id
which reach this timeout, parti [...]
-| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). | 500 | int
-| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used.In addition to the default class
specified below, you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round robin
assignments of partitions to consumers. Implementing the
org.apache.kafka.clients.con [...]
+| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). Note, that max.poll.records does not impact the
underlying fetching behavior. The consumer will cache the records from each
fetch request and returns them incrementally from each poll. | 500 | int
+| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used. Available options
are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor,
which works on a per-topic
basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions
to consumers in a round-r [...]
| *seekToOffset* (consumer) | Set if KafkaConsumer will read from a particular
offset on startup. This config will take precedence over seekTo config | | Long
| *seekToPosition* (consumer) | Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning end : read from end. There
are 2 enums and the value can be one of: beginning, end | | String
| *sessionTimeoutMs* (consumer) | The timeout used to detect client failures
when using Kafka's group management facility. The client sends periodic
heartbeats to indicate its liveness to the broker. If no heartbeats are
received by the broker before the expiration of this session timeout, then the
broker will remove this client from the group and initiate a rebalance. Note
that the value must be in the allowable range as configured in the broker
configuration by group.min.session.timeou [...]
@@ -148,7 +148,7 @@ with the following path and query parameters:
| *transactionTimeoutMs* (producer) | The maximum amount of time in ms that
the transaction coordinator will wait for a transaction status update from the
producer before proactively aborting the ongoing transaction.If this value is
larger than the transaction.max.timeout.ms setting in the broker, the request
will fail with a InvalidTxnTimeoutException error. | 1m | int
| *valueSerializer* (producer) | Serializer class for value that implements
the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
| *saslClientCallbackHandlerClass* (security) | The fully qualified name of a
SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: 'loginModuleClass
controlFlag (optionName=optionValue);'. For brokers, the config must be
prefixed with listener prefix and SASL mechanism name in lower-case. For
example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
+| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: loginModuleClass
controlFlag (optionName=optionValue);. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
| *saslKerberosKinitCmd* (security) | Kerberos kinit command path. |
/usr/bin/kinit | String
| *saslKerberosMinTimeBefore{zwsp}Relogin* (security) | Login thread sleep
time between refresh attempts. | 60000 | long
| *saslKerberosServiceName* (security) | The Kerberos principal name that
Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's
config. | | String
@@ -214,7 +214,7 @@ The Vert.x Kafka component supports 106 options, which are
listed below.
| *requestTimeoutMs* (common) | The configuration controls the maximum amount
of time the client will wait for the response of a request. If the response is
not received before the timeout elapses the client will resend the request if
necessary or fail the request if retries are exhausted. This should be larger
than replica.lag.time.max.ms (a broker configuration) to reduce the possibility
of message duplication due to unnecessary producer retries. | 30s | int
| *retryBackoffMs* (common) | The amount of time to wait before attempting to
retry a failed request to a given topic partition. This avoids repeatedly
sending requests in a tight loop under some failure scenarios. | 100ms | long
| *sendBufferBytes* (common) | The size of the TCP send buffer (SO_SNDBUF) to
use when sending data. If the value is -1, the OS default will be used. |
131072 | int
-| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 2m7s | long
+| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 30s | long
| *socketConnectionSetupTimeoutMs* (common) | The amount of time the client
will wait for the socket connection to be established. If the connection is not
built before the timeout elapses, clients will close the socket channel. | 10s
| long
| *allowAutoCreateTopics* (consumer) | Allow automatic topic creation on the
broker when subscribing to or assigning a topic. A topic being subscribed to
will be automatically created only if the broker allows for it using
auto.create.topics.enable broker configuration. This configuration must be set
to false when using brokers older than 0.11.0 | true | boolean
| *allowManualCommit* (consumer) | Whether to allow doing manual commits via
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit. If this
option is enabled then an instance of
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit is stored
on the Exchange message header, which allows end users to access this API and
perform manual offset commits via the Kafka consumer. Note: To take full
control of the offset committing, you may need to disable the Kafka C [...]
@@ -232,12 +232,12 @@ The Vert.x Kafka component supports 106 options, which
are listed below.
| *groupId* (consumer) | A unique string that identifies the consumer group
this consumer belongs to. This property is required if the consumer uses either
the group management functionality by using subscribe(topic) or the Kafka-based
offset management strategy. | | String
| *groupInstanceId* (consumer) | A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are permitted. If set, the
consumer is treated as a static member, which means that only one instance with
this ID is allowed in the consumer group at any time. This can be used in
combination with a larger session timeout to avoid group rebalances caused by
transient unavailability (e.g. process restarts). If not set, the consumer will
join the group as a dynami [...]
| *heartbeatIntervalMs* (consumer) | The expected time between heartbeats to
the consumer coordinator when using Kafka's group management facilities.
Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group. The value
must be set lower than session.timeout.ms, but typically should be set no
higher than 1/3 of that value. It can be adjusted even lower to control the
expected time for normal rebalances. [...]
-| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted'
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, c [...]
+| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, co [...]
| *keyDeserializer* (consumer) | Deserializer class for key that implements
the org.apache.kafka.common.serialization.Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
| *maxPartitionFetchBytes* (consumer) | The maximum amount of data
per-partition the server will return. Records are fetched in batches by the
consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). See fetch.max.bytes f [...]
| *maxPollIntervalMs* (consumer) | The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amount of time that the consumer can be idle before fetching more records. If
poll() is not called before expiration of this timeout, then the consumer is
considered failed and the group will rebalance in order to reassign the
partitions to another member. For consumers using a non-null group.instance.id
which reach this timeout, parti [...]
-| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). | 500 | int
-| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used.In addition to the default class
specified below, you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round robin
assignments of partitions to consumers. Implementing the
org.apache.kafka.clients.con [...]
+| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). Note, that max.poll.records does not impact the
underlying fetching behavior. The consumer will cache the records from each
fetch request and returns them incrementally from each poll. | 500 | int
+| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used. Available options
are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor,
which works on a per-topic
basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions
to consumers in a round-r [...]
| *seekToOffset* (consumer) | Set if KafkaConsumer will read from a particular
offset on startup. This config will take precedence over seekTo config | | Long
| *seekToPosition* (consumer) | Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning end : read from end. There
are 2 enums and the value can be one of: beginning, end | | String
| *sessionTimeoutMs* (consumer) | The timeout used to detect client failures
when using Kafka's group management facility. The client sends periodic
heartbeats to indicate its liveness to the broker. If no heartbeats are
received by the broker before the expiration of this session timeout, then the
broker will remove this client from the group and initiate a rebalance. Note
that the value must be in the allowable range as configured in the broker
configuration by group.min.session.timeou [...]
@@ -266,7 +266,7 @@ The Vert.x Kafka component supports 106 options, which are
listed below.
| *vertxKafkaClientFactory* (advanced) | *Autowired* Factory to use for
creating io.vertx.kafka.client.consumer.KafkaConsumer and
io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to
configure a custom factory to create custom KafkaConsumer and KafkaProducer
instances with logic that extends the vanilla VertX Kafka clients. | |
VertxKafkaClientFactory
| *vertxOptions* (advanced) | To provide a custom set of vertx options for
configuring vertx | | VertxOptions
| *saslClientCallbackHandlerClass* (security) | The fully qualified name of a
SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: 'loginModuleClass
controlFlag (optionName=optionValue);'. For brokers, the config must be
prefixed with listener prefix and SASL mechanism name in lower-case. For
example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
+| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: loginModuleClass
controlFlag (optionName=optionValue);. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
| *saslKerberosKinitCmd* (security) | Kerberos kinit command path. |
/usr/bin/kinit | String
| *saslKerberosMinTimeBefore{zwsp}Relogin* (security) | Login thread sleep
time between refresh attempts. | 60000 | long
| *saslKerberosServiceName* (security) | The Kerberos principal name that
Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's
config. | | String
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
index 3c60795..82c1914 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/VertxKafkaComponentBuilderFactory.java
@@ -432,7 +432,7 @@ public interface VertxKafkaComponentBuilderFactory {
*
* The option is a: <code>long</code> type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -781,7 +781,7 @@ public interface VertxKafkaComponentBuilderFactory {
/**
* Controls how to read messages written transactionally. If set to
* read_committed, consumer.poll() will only return transactional
- * messages which have been committed. If set to read_uncommitted' (the
+ * messages which have been committed. If set to read_uncommitted (the
* default), consumer.poll() will return all messages, even
* transactional messages which have been aborted. Non-transactional
* messages will be returned unconditionally in either mode. Messages
@@ -876,6 +876,9 @@ public interface VertxKafkaComponentBuilderFactory {
}
/**
* The maximum number of records returned in a single call to poll().
+ * Note, that max.poll.records does not impact the underlying fetching
+ * behavior. The consumer will cache the records from each fetch
request
+ * and returns them incrementally from each poll.
*
* The option is a: <code>int</code> type.
*
@@ -893,12 +896,19 @@ public interface VertxKafkaComponentBuilderFactory {
* A list of class names or class types, ordered by preference, of
* supported partition assignment strategies that the client will use
to
* distribute partition ownership amongst consumer instances when group
- * management is used.In addition to the default class specified below,
- * you can use the
- * org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round
- * robin assignments of partitions to consumers. Implementing the
+ * management is used. Available options
+ * are:org.apache.kafka.clients.consumer.RangeAssignor: The default
+ * assignor, which works on a per-topic
+ * basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns
+ * partitions to consumers in a round-robin
+ * fashion.org.apache.kafka.clients.consumer.StickyAssignor: Guarantees
+ * an assignment that is maximally balanced while preserving as many
+ * existing partition assignments as
+ *
possible.org.apache.kafka.clients.consumer.CooperativeStickyAssignor:
+ * Follows the same StickyAssignor logic, but allows for cooperative
+ * rebalancing.Implementing the
* org.apache.kafka.clients.consumer.ConsumerPartitionAssignor
interface
- * allows you to plug in a custom assignmentstrategy.
+ * allows you to plug in a custom assignment strategy.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1510,8 +1520,8 @@ public interface VertxKafkaComponentBuilderFactory {
/**
* JAAS login context parameters for SASL connections in the format
used
* by JAAS configuration files. JAAS configuration file format is
- * described here. The format for the value is: 'loginModuleClass
- * controlFlag (optionName=optionValue);'. For brokers, the config must
+ * described here. The format for the value is: loginModuleClass
+ * controlFlag (optionName=optionValue);. For brokers, the config must
* be prefixed with listener prefix and SASL mechanism name in
* lower-case. For example,
*
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required;.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
index 7d16558..beeebc5 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
@@ -656,7 +656,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option is a: <code>long</code> type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -677,7 +677,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option will be converted to a <code>long</code>
type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -1294,7 +1294,7 @@ public interface VertxKafkaEndpointBuilderFactory {
/**
* Controls how to read messages written transactionally. If set to
* read_committed, consumer.poll() will only return transactional
- * messages which have been committed. If set to read_uncommitted' (the
+ * messages which have been committed. If set to read_uncommitted (the
* default), consumer.poll() will return all messages, even
* transactional messages which have been aborted. Non-transactional
* messages will be returned unconditionally in either mode. Messages
@@ -1438,6 +1438,9 @@ public interface VertxKafkaEndpointBuilderFactory {
}
/**
* The maximum number of records returned in a single call to poll().
+ * Note, that max.poll.records does not impact the underlying fetching
+ * behavior. The consumer will cache the records from each fetch
request
+ * and returns them incrementally from each poll.
*
* The option is a: <code>int</code> type.
*
@@ -1454,6 +1457,9 @@ public interface VertxKafkaEndpointBuilderFactory {
}
/**
* The maximum number of records returned in a single call to poll().
+ * Note, that max.poll.records does not impact the underlying fetching
+ * behavior. The consumer will cache the records from each fetch
request
+ * and returns them incrementally from each poll.
*
* The option will be converted to a <code>int</code> type.
*
@@ -1472,12 +1478,19 @@ public interface VertxKafkaEndpointBuilderFactory {
* A list of class names or class types, ordered by preference, of
* supported partition assignment strategies that the client will use
to
* distribute partition ownership amongst consumer instances when group
- * management is used.In addition to the default class specified below,
- * you can use the
- * org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round
- * robin assignments of partitions to consumers. Implementing the
+ * management is used. Available options
+ * are:org.apache.kafka.clients.consumer.RangeAssignor: The default
+ * assignor, which works on a per-topic
+ * basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns
+ * partitions to consumers in a round-robin
+ * fashion.org.apache.kafka.clients.consumer.StickyAssignor: Guarantees
+ * an assignment that is maximally balanced while preserving as many
+ * existing partition assignments as
+ *
possible.org.apache.kafka.clients.consumer.CooperativeStickyAssignor:
+ * Follows the same StickyAssignor logic, but allows for cooperative
+ * rebalancing.Implementing the
* org.apache.kafka.clients.consumer.ConsumerPartitionAssignor
interface
- * allows you to plug in a custom assignmentstrategy.
+ * allows you to plug in a custom assignment strategy.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1622,8 +1635,8 @@ public interface VertxKafkaEndpointBuilderFactory {
/**
* JAAS login context parameters for SASL connections in the format
used
* by JAAS configuration files. JAAS configuration file format is
- * described here. The format for the value is: 'loginModuleClass
- * controlFlag (optionName=optionValue);'. For brokers, the config must
+ * described here. The format for the value is: loginModuleClass
+ * controlFlag (optionName=optionValue);. For brokers, the config must
* be prefixed with listener prefix and SASL mechanism name in
* lower-case. For example,
*
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required;.
@@ -3077,7 +3090,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option is a: <code>long</code> type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -3098,7 +3111,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option will be converted to a <code>long</code>
type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -3864,8 +3877,8 @@ public interface VertxKafkaEndpointBuilderFactory {
/**
* JAAS login context parameters for SASL connections in the format
used
* by JAAS configuration files. JAAS configuration file format is
- * described here. The format for the value is: 'loginModuleClass
- * controlFlag (optionName=optionValue);'. For brokers, the config must
+ * described here. The format for the value is: loginModuleClass
+ * controlFlag (optionName=optionValue);. For brokers, the config must
* be prefixed with listener prefix and SASL mechanism name in
* lower-case. For example,
*
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required;.
@@ -5240,7 +5253,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option is a: <code>long</code> type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -5261,7 +5274,7 @@ public interface VertxKafkaEndpointBuilderFactory {
*
* The option will be converted to a <code>long</code>
type.
*
- * Default: 2m7s
+ * Default: 30s
* Group: common
*
* @param socketConnectionSetupTimeoutMaxMs the value to set
@@ -5327,8 +5340,8 @@ public interface VertxKafkaEndpointBuilderFactory {
/**
* JAAS login context parameters for SASL connections in the format
used
* by JAAS configuration files. JAAS configuration file format is
- * described here. The format for the value is: 'loginModuleClass
- * controlFlag (optionName=optionValue);'. For brokers, the config must
+ * described here. The format for the value is: loginModuleClass
+ * controlFlag (optionName=optionValue);. For brokers, the config must
* be prefixed with listener prefix and SASL mechanism name in
* lower-case. For example,
*
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required;.
diff --git a/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
b/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
index 04678e9..5b22be8 100644
--- a/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
+++ b/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
@@ -101,7 +101,7 @@ with the following path and query parameters:
| *requestTimeoutMs* (common) | The configuration controls the maximum amount
of time the client will wait for the response of a request. If the response is
not received before the timeout elapses the client will resend the request if
necessary or fail the request if retries are exhausted. This should be larger
than replica.lag.time.max.ms (a broker configuration) to reduce the possibility
of message duplication due to unnecessary producer retries. | 30s | int
| *retryBackoffMs* (common) | The amount of time to wait before attempting to
retry a failed request to a given topic partition. This avoids repeatedly
sending requests in a tight loop under some failure scenarios. | 100ms | long
| *sendBufferBytes* (common) | The size of the TCP send buffer (SO_SNDBUF) to
use when sending data. If the value is -1, the OS default will be used. |
131072 | int
-| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 2m7s | long
+| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 30s | long
| *socketConnectionSetupTimeoutMs* (common) | The amount of time the client
will wait for the socket connection to be established. If the connection is not
built before the timeout elapses, clients will close the socket channel. | 10s
| long
| *allowAutoCreateTopics* (consumer) | Allow automatic topic creation on the
broker when subscribing to or assigning a topic. A topic being subscribed to
will be automatically created only if the broker allows for it using
auto.create.topics.enable broker configuration. This configuration must be set
to false when using brokers older than 0.11.0 | true | boolean
| *allowManualCommit* (consumer) | Whether to allow doing manual commits via
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit. If this
option is enabled then an instance of
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit is stored
on the Exchange message header, which allows end users to access this API and
perform manual offset commits via the Kafka consumer. Note: To take full
control of the offset committing, you may need to disable the Kafka C [...]
@@ -119,12 +119,12 @@ with the following path and query parameters:
| *groupId* (consumer) | A unique string that identifies the consumer group
this consumer belongs to. This property is required if the consumer uses either
the group management functionality by using subscribe(topic) or the Kafka-based
offset management strategy. | | String
| *groupInstanceId* (consumer) | A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are permitted. If set, the
consumer is treated as a static member, which means that only one instance with
this ID is allowed in the consumer group at any time. This can be used in
combination with a larger session timeout to avoid group rebalances caused by
transient unavailability (e.g. process restarts). If not set, the consumer will
join the group as a dynami [...]
| *heartbeatIntervalMs* (consumer) | The expected time between heartbeats to
the consumer coordinator when using Kafka's group management facilities.
Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group. The value
must be set lower than session.timeout.ms, but typically should be set no
higher than 1/3 of that value. It can be adjusted even lower to control the
expected time for normal rebalances. [...]
-| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted'
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, c [...]
+| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, co [...]
| *keyDeserializer* (consumer) | Deserializer class for key that implements
the org.apache.kafka.common.serialization.Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
| *maxPartitionFetchBytes* (consumer) | The maximum amount of data
per-partition the server will return. Records are fetched in batches by the
consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). See fetch.max.bytes f [...]
| *maxPollIntervalMs* (consumer) | The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amount of time that the consumer can be idle before fetching more records. If
poll() is not called before expiration of this timeout, then the consumer is
considered failed and the group will rebalance in order to reassign the
partitions to another member. For consumers using a non-null group.instance.id
which reach this timeout, parti [...]
-| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). | 500 | int
-| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used.In addition to the default class
specified below, you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round robin
assignments of partitions to consumers. Implementing the
org.apache.kafka.clients.con [...]
+| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). Note, that max.poll.records does not impact the
underlying fetching behavior. The consumer will cache the records from each
fetch request and returns them incrementally from each poll. | 500 | int
+| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used. Available options
are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor,
which works on a per-topic
basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions
to consumers in a round-r [...]
| *seekToOffset* (consumer) | Set if KafkaConsumer will read from a particular
offset on startup. This config will take precedence over seekTo config | | Long
| *seekToPosition* (consumer) | Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning end : read from end. There
are 2 enums and the value can be one of: beginning, end | | String
| *sessionTimeoutMs* (consumer) | The timeout used to detect client failures
when using Kafka's group management facility. The client sends periodic
heartbeats to indicate its liveness to the broker. If no heartbeats are
received by the broker before the expiration of this session timeout, then the
broker will remove this client from the group and initiate a rebalance. Note
that the value must be in the allowable range as configured in the broker
configuration by group.min.session.timeou [...]
@@ -150,7 +150,7 @@ with the following path and query parameters:
| *transactionTimeoutMs* (producer) | The maximum amount of time in ms that
the transaction coordinator will wait for a transaction status update from the
producer before proactively aborting the ongoing transaction.If this value is
larger than the transaction.max.timeout.ms setting in the broker, the request
will fail with a InvalidTxnTimeoutException error. | 1m | int
| *valueSerializer* (producer) | Serializer class for value that implements
the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
| *saslClientCallbackHandlerClass* (security) | The fully qualified name of a
SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: 'loginModuleClass
controlFlag (optionName=optionValue);'. For brokers, the config must be
prefixed with listener prefix and SASL mechanism name in lower-case. For
example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
+| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: loginModuleClass
controlFlag (optionName=optionValue);. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
| *saslKerberosKinitCmd* (security) | Kerberos kinit command path. |
/usr/bin/kinit | String
| *saslKerberosMinTimeBefore{zwsp}Relogin* (security) | Login thread sleep
time between refresh attempts. | 60000 | long
| *saslKerberosServiceName* (security) | The Kerberos principal name that
Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's
config. | | String
@@ -216,7 +216,7 @@ The Vert.x Kafka component supports 106 options, which are
listed below.
| *requestTimeoutMs* (common) | The configuration controls the maximum amount
of time the client will wait for the response of a request. If the response is
not received before the timeout elapses the client will resend the request if
necessary or fail the request if retries are exhausted. This should be larger
than replica.lag.time.max.ms (a broker configuration) to reduce the possibility
of message duplication due to unnecessary producer retries. | 30s | int
| *retryBackoffMs* (common) | The amount of time to wait before attempting to
retry a failed request to a given topic partition. This avoids repeatedly
sending requests in a tight loop under some failure scenarios. | 100ms | long
| *sendBufferBytes* (common) | The size of the TCP send buffer (SO_SNDBUF) to
use when sending data. If the value is -1, the OS default will be used. |
131072 | int
-| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 2m7s | long
+| *socketConnectionSetupTimeout{zwsp}MaxMs* (common) | The maximum amount of
time the client will wait for the socket connection to be established. The
connection setup timeout will increase exponentially for each consecutive
connection failure up to this maximum. To avoid connection storms, a
randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. | 30s | long
| *socketConnectionSetupTimeoutMs* (common) | The amount of time the client
will wait for the socket connection to be established. If the connection is not
built before the timeout elapses, clients will close the socket channel. | 10s
| long
| *allowAutoCreateTopics* (consumer) | Allow automatic topic creation on the
broker when subscribing to or assigning a topic. A topic being subscribed to
will be automatically created only if the broker allows for it using
auto.create.topics.enable broker configuration. This configuration must be set
to false when using brokers older than 0.11.0 | true | boolean
| *allowManualCommit* (consumer) | Whether to allow doing manual commits via
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit. If this
option is enabled then an instance of
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit is stored
on the Exchange message header, which allows end users to access this API and
perform manual offset commits via the Kafka consumer. Note: To take full
control of the offset committing, you may need to disable the Kafka C [...]
@@ -234,12 +234,12 @@ The Vert.x Kafka component supports 106 options, which
are listed below.
| *groupId* (consumer) | A unique string that identifies the consumer group
this consumer belongs to. This property is required if the consumer uses either
the group management functionality by using subscribe(topic) or the Kafka-based
offset management strategy. | | String
| *groupInstanceId* (consumer) | A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are permitted. If set, the
consumer is treated as a static member, which means that only one instance with
this ID is allowed in the consumer group at any time. This can be used in
combination with a larger session timeout to avoid group rebalances caused by
transient unavailability (e.g. process restarts). If not set, the consumer will
join the group as a dynami [...]
| *heartbeatIntervalMs* (consumer) | The expected time between heartbeats to
the consumer coordinator when using Kafka's group management facilities.
Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group. The value
must be set lower than session.timeout.ms, but typically should be set no
higher than 1/3 of that value. It can be adjusted even lower to control the
expected time for normal rebalances. [...]
-| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted'
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, c [...]
+| *isolationLevel* (consumer) | Controls how to read messages written
transactionally. If set to read_committed, consumer.poll() will only return
transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional
messages which have been aborted. Non-transactional messages will be returned
unconditionally in either mode. Messages will always be returned in offset
order. Hence, in read_committed mode, co [...]
| *keyDeserializer* (consumer) | Deserializer class for key that implements
the org.apache.kafka.common.serialization.Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
| *maxPartitionFetchBytes* (consumer) | The maximum amount of data
per-partition the server will return. Records are fetched in batches by the
consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). See fetch.max.bytes f [...]
| *maxPollIntervalMs* (consumer) | The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amount of time that the consumer can be idle before fetching more records. If
poll() is not called before expiration of this timeout, then the consumer is
considered failed and the group will rebalance in order to reassign the
partitions to another member. For consumers using a non-null group.instance.id
which reach this timeout, parti [...]
-| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). | 500 | int
-| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used.In addition to the default class
specified below, you can use the
org.apache.kafka.clients.consumer.RoundRobinAssignorclass for round robin
assignments of partitions to consumers. Implementing the
org.apache.kafka.clients.con [...]
+| *maxPollRecords* (consumer) | The maximum number of records returned in a
single call to poll(). Note, that max.poll.records does not impact the
underlying fetching behavior. The consumer will cache the records from each
fetch request and returns them incrementally from each poll. | 500 | int
+| *partitionAssignmentStrategy* (consumer) | A list of class names or class
types, ordered by preference, of supported partition assignment strategies that
the client will use to distribute partition ownership amongst consumer
instances when group management is used. Available options
are:org.apache.kafka.clients.consumer.RangeAssignor: The default assignor,
which works on a per-topic
basis.org.apache.kafka.clients.consumer.RoundRobinAssignor: Assigns partitions
to consumers in a round-r [...]
| *seekToOffset* (consumer) | Set if KafkaConsumer will read from a particular
offset on startup. This config will take precedence over seekTo config | | Long
| *seekToPosition* (consumer) | Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning end : read from end. There
are 2 enums and the value can be one of: beginning, end | | String
| *sessionTimeoutMs* (consumer) | The timeout used to detect client failures
when using Kafka's group management facility. The client sends periodic
heartbeats to indicate its liveness to the broker. If no heartbeats are
received by the broker before the expiration of this session timeout, then the
broker will remove this client from the group and initiate a rebalance. Note
that the value must be in the allowable range as configured in the broker
configuration by group.min.session.timeou [...]
@@ -268,7 +268,7 @@ The Vert.x Kafka component supports 106 options, which are
listed below.
| *vertxKafkaClientFactory* (advanced) | *Autowired* Factory to use for
creating io.vertx.kafka.client.consumer.KafkaConsumer and
io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to
configure a custom factory to create custom KafkaConsumer and KafkaProducer
instances with logic that extends the vanilla VertX Kafka clients. | |
VertxKafkaClientFactory
| *vertxOptions* (advanced) | To provide a custom set of vertx options for
configuring vertx | | VertxOptions
| *saslClientCallbackHandlerClass* (security) | The fully qualified name of a
SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: 'loginModuleClass
controlFlag (optionName=optionValue);'. For brokers, the config must be
prefixed with listener prefix and SASL mechanism name in lower-case. For
example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
+| *saslJaasConfig* (security) | JAAS login context parameters for SASL
connections in the format used by JAAS configuration files. JAAS configuration
file format is described here. The format for the value is: loginModuleClass
controlFlag (optionName=optionValue);. For brokers, the config must be prefixed
with listener prefix and SASL mechanism name in lower-case. For example,
listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule
required; | | String
| *saslKerberosKinitCmd* (security) | Kerberos kinit command path. |
/usr/bin/kinit | String
| *saslKerberosMinTimeBefore{zwsp}Relogin* (security) | Login thread sleep
time between refresh attempts. | 60000 | long
| *saslKerberosServiceName* (security) | The Kerberos principal name that
Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's
config. | | String
