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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 72e517f [create-pull-request] automated change
72e517f is described below
commit 72e517fc7d929189e0b0cc57bec8cd70fa45757b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun May 9 01:28:19 2021 +0000
[create-pull-request] automated change
---
.../springboot/catalog/components/vertx-kafka.json | 20 +++++++--------
.../src/main/docs/vertx-kafka-starter.adoc | 10 ++++----
.../VertxKafkaComponentConfiguration.java | 29 +++++++++++++++-------
docs/modules/ROOT/pages/vertx-kafka-starter.adoc | 10 ++++----
4 files changed, 40 insertions(+), 29 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
index ba99555..bf635d4 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json
@@ -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-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
index 098a7c5..2b89714 100644
---
a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
+++
b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc
@@ -56,7 +56,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.header-filter-strategy* | To use a custom
HeaderFilterStrategy to filter header to and from Camel message. The option is
a org.apache.camel.spi.HeaderFilterStrategy type. | | HeaderFilterStrategy
| *camel.component.vertx-kafka.heartbeat-interval-ms* | 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 [...]
| *camel.component.vertx-kafka.interceptor-classes* | A list of classes to use
as interceptors. Implementing the
org.apache.kafka.clients.producer.ProducerInterceptor interface allows you to
intercept (and possibly mutate) the records received by the producer before
they are published to the Kafka cluster. By default, there are no interceptors.
| | String
-| *camel.component.vertx-kafka.isolation-level* | 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 [...]
+| *camel.component.vertx-kafka.isolation-level* | 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_ [...]
| *camel.component.vertx-kafka.kafka-manual-commit-factory* | Factory to use
for creating
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances.
This allows to plugin a custom factory to create custom
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances
in case special logic is needed when doing manual commits that deviates from
the default implementation that comes out of the box. The option is a
org.apache.camel.component.vertx.kafka.o [...]
| *camel.component.vertx-kafka.key-deserializer* | Deserializer class for key
that implements the org.apache.kafka.common.serialization.Deserializer
interface. | org.apache.kafka.common.serialization.StringDeserializer | String
| *camel.component.vertx-kafka.key-serializer* | Serializer class for key that
implements the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
@@ -66,7 +66,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.max-in-flight-requests-per-connection* | The
maximum number of unacknowledged requests the client will send on a single
connection before blocking. Note that if this setting is set to be greater than
1 and there are failed sends, there is a risk of message re-ordering due to
retries (i.e., if retries are enabled). | 5 | Integer
| *camel.component.vertx-kafka.max-partition-fetch-bytes* | The maximum amount
of data per-partition the server will return. Records are fetched in batches by
the consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). S [...]
| *camel.component.vertx-kafka.max-poll-interval-ms* | The maximum delay
between invocations of poll() when using consumer group management. This places
an upper bound on the amount of time that the consumer can be idle before
fetching more records. If poll() is not called before expiration of this
timeout, then the consumer is considered failed and the group will rebalance in
order to reassign the partitions to another member. For consumers using a
non-null group.instance.id which reach [...]
-| *camel.component.vertx-kafka.max-poll-records* | The maximum number of
records returned in a single call to poll(). | 500 | Integer
+| *camel.component.vertx-kafka.max-poll-records* | 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 | Integer
| *camel.component.vertx-kafka.max-request-size* | The maximum size of a
request in bytes. This setting will limit the number of record batches the
producer will send in a single request to avoid sending huge requests. This is
also effectively a cap on the maximum uncompressed record batch size. Note that
the server has its own cap on the record batch size (after compression if
compression is enabled) which may be different from this. | 1048576 | Integer
| *camel.component.vertx-kafka.metadata-max-age-ms* | The period of time in
milliseconds after which we force a refresh of metadata even if we haven't seen
any partition leadership changes to proactively discover any new brokers or
partitions. The option is a long type. | 300000 | Long
| *camel.component.vertx-kafka.metadata-max-idle-ms* | Controls how long the
producer will cache metadata for a topic that's idle. If the elapsed time since
a topic was last produced to exceeds the metadata idle duration, then the
topic's metadata is forgotten and the next access to it will force a metadata
fetch request. The option is a long type. | 300000 | Long
@@ -74,7 +74,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.metrics-num-samples* | The number of samples
maintained to compute metrics. | 2 | Integer
| *camel.component.vertx-kafka.metrics-recording-level* | The highest
recording level for metrics. | INFO | String
| *camel.component.vertx-kafka.metrics-sample-window-ms* | The window of time
a metrics sample is computed over. The option is a long type. | 30000 | Long
-| *camel.component.vertx-kafka.partition-assignment-strategy* | 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.apach [...]
+| *camel.component.vertx-kafka.partition-assignment-strategy* | 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 con [...]
| *camel.component.vertx-kafka.partition-id* | The partition to which the
record will be sent (or null if no partition was specified) or read from a
particular partition if set. Header VertxKafkaConstants#PARTITION_ID If
configured, it will take precedence over this config | | Integer
| *camel.component.vertx-kafka.partitioner-class* | Partitioner class that
implements the org.apache.kafka.clients.producer.Partitioner interface. |
org.apache.kafka.clients.producer.internals.DefaultPartitioner | String
| *camel.component.vertx-kafka.receive-buffer-bytes* | The size of the TCP
receive buffer (SO_RCVBUF) to use when reading data. If the value is -1, the OS
default will be used. | 32768 | Integer
@@ -84,7 +84,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.retries* | Setting a value greater than zero
will cause the client to resend any record whose send fails with a potentially
transient error. Note that this retry is no different than if the client resent
the record upon receiving the error. Allowing retries without setting
max.in.flight.requests.per.connection to 1 will potentially change the ordering
of records because if two batches are sent to a single partition, and the first
fails and is retried but th [...]
| *camel.component.vertx-kafka.retry-backoff-ms* | 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. The option is a long type. | 100 | Long
| *camel.component.vertx-kafka.sasl-client-callback-handler-class* | The fully
qualified name of a SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *camel.component.vertx-kafka.sasl-jaas-config* | 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 [...]
+| *camel.component.vertx-kafka.sasl-jaas-config* | 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; [...]
| *camel.component.vertx-kafka.sasl-kerberos-kinit-cmd* | Kerberos kinit
command path. | /usr/bin/kinit | String
| *camel.component.vertx-kafka.sasl-kerberos-min-time-before-relogin* | Login
thread sleep time between refresh attempts. | 60000 | Long
| *camel.component.vertx-kafka.sasl-kerberos-service-name* | The Kerberos
principal name that Kafka runs as. This can be defined either in Kafka's JAAS
config or in Kafka's config. | | String
@@ -103,7 +103,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.seek-to-position* | Set if KafkaConsumer will
read from beginning or end on startup: beginning : read from beginning end :
read from end. | | String
| *camel.component.vertx-kafka.send-buffer-bytes* | The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the value is -1, the OS default
will be used. | 131072 | Integer
| *camel.component.vertx-kafka.session-timeout-ms* | The timeout used to
detect client failures when using Kafka's group management facility. The client
sends periodic heartbeats to indicate its liveness to the broker. If no
heartbeats are received by the broker before the expiration of this session
timeout, then the broker will remove this client from the group and initiate a
rebalance. Note that the value must be in the allowable range as configured in
the broker configuration by group [...]
-| *camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms* | The
maximum amount of time the client will wait for the socket connection to be
established. The connection setup timeout will increase exponentially for each
consecutive connection failure up to this maximum. To avoid connection storms,
a randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. The option is
a long type. | 127000 | Long
+| *camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms* | The
maximum amount of time the client will wait for the socket connection to be
established. The connection setup timeout will increase exponentially for each
consecutive connection failure up to this maximum. To avoid connection storms,
a randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. The option is
a long type. | 30000 | Long
| *camel.component.vertx-kafka.socket-connection-setup-timeout-ms* | The
amount of time the client will wait for the socket connection to be
established. If the connection is not built before the timeout elapses, clients
will close the socket channel. The option is a long type. | 10000 | Long
| *camel.component.vertx-kafka.ssl-cipher-suites* | A list of cipher suites.
This is a named combination of authentication, encryption, MAC and key exchange
algorithm used to negotiate the security settings for a network connection
using TLS or SSL network protocol. By default all the available cipher suites
are supported. | | String
| *camel.component.vertx-kafka.ssl-enabled-protocols* | The list of protocols
enabled for SSL connections. The default is 'TLSv1.2,TLSv1.3' when running with
Java 11 or newer, 'TLSv1.2' otherwise. With the default value for Java 11,
clients and servers will prefer TLSv1.3 if both support it and fallback to
TLSv1.2 otherwise (assuming both support at least TLSv1.2). This default should
be fine for most cases. Also see the config documentation for ssl.protocol. |
TLSv1.2,TLSv1.3 | String
diff --git
a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
index ce04a5e..9ac4f10 100644
---
a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
+++
b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java
@@ -191,7 +191,7 @@ public class VertxKafkaComponentConfiguration
* to the timeout resulting in a random range between 20% below and 20%
* above the computed value. The option is a long type.
*/
- private Long socketConnectionSetupTimeoutMaxMs = 127000L;
+ private Long socketConnectionSetupTimeoutMaxMs = 30000L;
/**
* 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,
@@ -331,7 +331,7 @@ public class VertxKafkaComponentConfiguration
/**
* 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),
+ * 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
@@ -375,18 +375,29 @@ public class VertxKafkaComponentConfiguration
*/
private Integer maxPollIntervalMs = 300000;
/**
- * 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 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.
*/
private Integer maxPollRecords = 500;
/**
* 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
+ * 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.
*/
private String partitionAssignmentStrategy =
"org.apache.kafka.clients.consumer.RangeAssignor";
/**
@@ -663,8 +674,8 @@ public class VertxKafkaComponentConfiguration
/**
* 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
+ * 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/modules/ROOT/pages/vertx-kafka-starter.adoc
b/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
index 098a7c5..2b89714 100644
--- a/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
+++ b/docs/modules/ROOT/pages/vertx-kafka-starter.adoc
@@ -56,7 +56,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.header-filter-strategy* | To use a custom
HeaderFilterStrategy to filter header to and from Camel message. The option is
a org.apache.camel.spi.HeaderFilterStrategy type. | | HeaderFilterStrategy
| *camel.component.vertx-kafka.heartbeat-interval-ms* | 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 [...]
| *camel.component.vertx-kafka.interceptor-classes* | A list of classes to use
as interceptors. Implementing the
org.apache.kafka.clients.producer.ProducerInterceptor interface allows you to
intercept (and possibly mutate) the records received by the producer before
they are published to the Kafka cluster. By default, there are no interceptors.
| | String
-| *camel.component.vertx-kafka.isolation-level* | 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 [...]
+| *camel.component.vertx-kafka.isolation-level* | 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_ [...]
| *camel.component.vertx-kafka.kafka-manual-commit-factory* | Factory to use
for creating
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances.
This allows to plugin a custom factory to create custom
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances
in case special logic is needed when doing manual commits that deviates from
the default implementation that comes out of the box. The option is a
org.apache.camel.component.vertx.kafka.o [...]
| *camel.component.vertx-kafka.key-deserializer* | Deserializer class for key
that implements the org.apache.kafka.common.serialization.Deserializer
interface. | org.apache.kafka.common.serialization.StringDeserializer | String
| *camel.component.vertx-kafka.key-serializer* | Serializer class for key that
implements the org.apache.kafka.common.serialization.Serializer interface. |
org.apache.kafka.common.serialization.StringSerializer | String
@@ -66,7 +66,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.max-in-flight-requests-per-connection* | The
maximum number of unacknowledged requests the client will send on a single
connection before blocking. Note that if this setting is set to be greater than
1 and there are failed sends, there is a risk of message re-ordering due to
retries (i.e., if retries are enabled). | 5 | Integer
| *camel.component.vertx-kafka.max-partition-fetch-bytes* | The maximum amount
of data per-partition the server will return. Records are fetched in batches by
the consumer. If the first record batch in the first non-empty partition of the
fetch is larger than this limit, the batch will still be returned to ensure
that the consumer can make progress. The maximum record batch size accepted by
the broker is defined via message.max.bytes (broker config) or
max.message.bytes (topic config). S [...]
| *camel.component.vertx-kafka.max-poll-interval-ms* | The maximum delay
between invocations of poll() when using consumer group management. This places
an upper bound on the amount of time that the consumer can be idle before
fetching more records. If poll() is not called before expiration of this
timeout, then the consumer is considered failed and the group will rebalance in
order to reassign the partitions to another member. For consumers using a
non-null group.instance.id which reach [...]
-| *camel.component.vertx-kafka.max-poll-records* | The maximum number of
records returned in a single call to poll(). | 500 | Integer
+| *camel.component.vertx-kafka.max-poll-records* | 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 | Integer
| *camel.component.vertx-kafka.max-request-size* | The maximum size of a
request in bytes. This setting will limit the number of record batches the
producer will send in a single request to avoid sending huge requests. This is
also effectively a cap on the maximum uncompressed record batch size. Note that
the server has its own cap on the record batch size (after compression if
compression is enabled) which may be different from this. | 1048576 | Integer
| *camel.component.vertx-kafka.metadata-max-age-ms* | The period of time in
milliseconds after which we force a refresh of metadata even if we haven't seen
any partition leadership changes to proactively discover any new brokers or
partitions. The option is a long type. | 300000 | Long
| *camel.component.vertx-kafka.metadata-max-idle-ms* | Controls how long the
producer will cache metadata for a topic that's idle. If the elapsed time since
a topic was last produced to exceeds the metadata idle duration, then the
topic's metadata is forgotten and the next access to it will force a metadata
fetch request. The option is a long type. | 300000 | Long
@@ -74,7 +74,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.metrics-num-samples* | The number of samples
maintained to compute metrics. | 2 | Integer
| *camel.component.vertx-kafka.metrics-recording-level* | The highest
recording level for metrics. | INFO | String
| *camel.component.vertx-kafka.metrics-sample-window-ms* | The window of time
a metrics sample is computed over. The option is a long type. | 30000 | Long
-| *camel.component.vertx-kafka.partition-assignment-strategy* | 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.apach [...]
+| *camel.component.vertx-kafka.partition-assignment-strategy* | 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 con [...]
| *camel.component.vertx-kafka.partition-id* | The partition to which the
record will be sent (or null if no partition was specified) or read from a
particular partition if set. Header VertxKafkaConstants#PARTITION_ID If
configured, it will take precedence over this config | | Integer
| *camel.component.vertx-kafka.partitioner-class* | Partitioner class that
implements the org.apache.kafka.clients.producer.Partitioner interface. |
org.apache.kafka.clients.producer.internals.DefaultPartitioner | String
| *camel.component.vertx-kafka.receive-buffer-bytes* | The size of the TCP
receive buffer (SO_RCVBUF) to use when reading data. If the value is -1, the OS
default will be used. | 32768 | Integer
@@ -84,7 +84,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.retries* | Setting a value greater than zero
will cause the client to resend any record whose send fails with a potentially
transient error. Note that this retry is no different than if the client resent
the record upon receiving the error. Allowing retries without setting
max.in.flight.requests.per.connection to 1 will potentially change the ordering
of records because if two batches are sent to a single partition, and the first
fails and is retried but th [...]
| *camel.component.vertx-kafka.retry-backoff-ms* | 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. The option is a long type. | 100 | Long
| *camel.component.vertx-kafka.sasl-client-callback-handler-class* | The fully
qualified name of a SASL client callback handler class that implements the
AuthenticateCallbackHandler interface. | | String
-| *camel.component.vertx-kafka.sasl-jaas-config* | 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 [...]
+| *camel.component.vertx-kafka.sasl-jaas-config* | 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; [...]
| *camel.component.vertx-kafka.sasl-kerberos-kinit-cmd* | Kerberos kinit
command path. | /usr/bin/kinit | String
| *camel.component.vertx-kafka.sasl-kerberos-min-time-before-relogin* | Login
thread sleep time between refresh attempts. | 60000 | Long
| *camel.component.vertx-kafka.sasl-kerberos-service-name* | The Kerberos
principal name that Kafka runs as. This can be defined either in Kafka's JAAS
config or in Kafka's config. | | String
@@ -103,7 +103,7 @@ The component supports 107 options, which are listed below.
| *camel.component.vertx-kafka.seek-to-position* | Set if KafkaConsumer will
read from beginning or end on startup: beginning : read from beginning end :
read from end. | | String
| *camel.component.vertx-kafka.send-buffer-bytes* | The size of the TCP send
buffer (SO_SNDBUF) to use when sending data. If the value is -1, the OS default
will be used. | 131072 | Integer
| *camel.component.vertx-kafka.session-timeout-ms* | The timeout used to
detect client failures when using Kafka's group management facility. The client
sends periodic heartbeats to indicate its liveness to the broker. If no
heartbeats are received by the broker before the expiration of this session
timeout, then the broker will remove this client from the group and initiate a
rebalance. Note that the value must be in the allowable range as configured in
the broker configuration by group [...]
-| *camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms* | The
maximum amount of time the client will wait for the socket connection to be
established. The connection setup timeout will increase exponentially for each
consecutive connection failure up to this maximum. To avoid connection storms,
a randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. The option is
a long type. | 127000 | Long
+| *camel.component.vertx-kafka.socket-connection-setup-timeout-max-ms* | The
maximum amount of time the client will wait for the socket connection to be
established. The connection setup timeout will increase exponentially for each
consecutive connection failure up to this maximum. To avoid connection storms,
a randomization factor of 0.2 will be applied to the timeout resulting in a
random range between 20% below and 20% above the computed value. The option is
a long type. | 30000 | Long
| *camel.component.vertx-kafka.socket-connection-setup-timeout-ms* | The
amount of time the client will wait for the socket connection to be
established. If the connection is not built before the timeout elapses, clients
will close the socket channel. The option is a long type. | 10000 | Long
| *camel.component.vertx-kafka.ssl-cipher-suites* | A list of cipher suites.
This is a named combination of authentication, encryption, MAC and key exchange
algorithm used to negotiate the security settings for a network connection
using TLS or SSL network protocol. By default all the available cipher suites
are supported. | | String
| *camel.component.vertx-kafka.ssl-enabled-protocols* | The list of protocols
enabled for SSL connections. The default is 'TLSv1.2,TLSv1.3' when running with
Java 11 or newer, 'TLSv1.2' otherwise. With the default value for Java 11,
clients and servers will prefer TLSv1.3 if both support it and fallback to
TLSv1.2 otherwise (assuming both support at least TLSv1.2). This default should
be fine for most cases. Also see the config documentation for ssl.protocol. |
TLSv1.2,TLSv1.3 | String
