This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new ba682b8fe96 Regen
ba682b8fe96 is described below
commit ba682b8fe96b231fa9f6b096042cd3693d44fade
Author: Claus Ibsen <[email protected]>
AuthorDate: Tue Jul 11 06:53:10 2023 +0200
Regen
---
.../camel/springboot/catalog/components/kafka.json | 40 +++++------
.../camel-kafka-starter/src/main/docs/kafka.json | 22 +++---
.../springboot/KafkaComponentConfiguration.java | 79 +++++++++++-----------
3 files changed, 72 insertions(+), 69 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
index ecf26f6606f..6584694daea 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
@@ -33,7 +33,7 @@
"autoCommitEnable": { "index": 8, "kind": "property", "displayName": "Auto
Commit Enable", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "If true, periodically commit to ZooKeeper the
offset of messages already fetched b [...]
"autoCommitIntervalMs": { "index": 9, "kind": "property", "displayName":
"Auto Commit Interval Ms", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"5000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The frequency in ms that the consumer offsets
are committed t [...]
"autoOffsetReset": { "index": 10, "kind": "property", "displayName": "Auto
Offset Reset", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "latest",
"earliest", "none" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "latest", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "What to do when there is no i [...]
- "breakOnFirstError": { "index": 11, "kind": "property", "displayName":
"Break On First Error", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This options controls
what happens when a consumer is processing an exchange [...]
+ "breakOnFirstError": { "index": 11, "kind": "property", "displayName":
"Break On First Error", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This options controls
what happens when a consumer is processing an exchange [...]
"bridgeErrorHandler": { "index": 12, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions occurred while the consumer is trying to pickup incoming
messages, or the likes, will now be proc [...]
"checkCrcs": { "index": 13, "kind": "property", "displayName": "Check
Crcs", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Automatically check the CRC32 of the records
consumed. This ensures no on-the-wire o [...]
"commitTimeoutMs": { "index": 14, "kind": "property", "displayName":
"Commit Timeout Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The maximum time, in
milliseconds, that the code will wait for a synchron [...]
@@ -46,7 +46,7 @@
"groupInstanceId": { "index": 21, "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.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A unique identifier of the consumer instance
provided by the end user. Only non-empty strings are [...]
"headerDeserializer": { "index": 22, "kind": "property", "displayName":
"Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to des
[...]
"heartbeatIntervalMs": { "index": 23, "kind": "property", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "3000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinato [...]
- "keyDeserializer": { "index": 24, "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.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
[...]
+ "keyDeserializer": { "index": 24, "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.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
[...]
"maxPartitionFetchBytes": { "index": 25, "kind": "property",
"displayName": "Max Partition Fetch Bytes", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server w [...]
"maxPollIntervalMs": { "index": 26, "kind": "property", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. Thi [...]
"maxPollRecords": { "index": 27, "kind": "property", "displayName": "Max
Poll Records", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "500",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()" },
@@ -54,18 +54,18 @@
"partitionAssignor": { "index": 29, "kind": "property", "displayName":
"Partition Assignor", "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.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The class name of the parti [...]
"pollOnError": { "index": 30, "kind": "property", "displayName": "Poll On
Error", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [
"DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "ERROR_HANDLER",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "config [...]
"pollTimeoutMs": { "index": 31, "kind": "property", "displayName": "Poll
Timeout Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used when
polling the KafkaConsumer." },
- "seekTo": { "index": 32, "kind": "property", "displayName": "Seek To",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.kafka.SeekPolicy", "enum": [
"BEGINNING", "END" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end on s [...]
+ "seekTo": { "index": 32, "kind": "property", "displayName": "Seek To",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.kafka.SeekPolicy", "enum": [
"BEGINNING", "END" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from the beginning or the [...]
"sessionTimeoutMs": { "index": 33, "kind": "property", "displayName":
"Session Timeout Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect failures when using Kafka's group managem [...]
"specificAvroReader": { "index": 34, "kind": "property", "displayName":
"Specific Avro Reader", "group": "consumer", "label": "confluent,consumer",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This enables the use of
a specific Avro reader for use with the Co [...]
"topicIsPattern": { "index": 35, "kind": "property", "displayName": "Topic
Is Pattern", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the topic is a pattern (regular
expression). This can be used to subscribe t [...]
"valueDeserializer": { "index": 36, "kind": "property", "displayName":
"Value Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class [...]
"createConsumerBackoffInterval": { "index": 37, "kind": "property",
"displayName": "Create Consumer Backoff Interval", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 5000, "description": "The delay in millis
seconds to wait before trying again to create the kafka consumer
(kafka-client)." },
- "createConsumerBackoffMaxAttempts": { "index": 38, "kind": "property",
"displayName": "Create Consumer Backoff Max Attempts", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "description": "Maximum attempts to create the kafka consumer
(kafka-client), before eventually giving up and failing. Error during creating
the consumer may be fatal due to invalid con [...]
+ "createConsumerBackoffMaxAttempts": { "index": 38, "kind": "property",
"displayName": "Create Consumer Backoff Max Attempts", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "description": "Maximum attempts to create the kafka consumer
(kafka-client), before eventually giving up and failing. Error during creating
the consumer may be fatal due to invalid con [...]
"isolationLevel": { "index": 39, "kind": "property", "displayName":
"Isolation Level", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "read_uncommitted", "read_committed" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"read_uncommitted", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "descripti [...]
"kafkaManualCommitFactory": { "index": 40, "kind": "property",
"displayName": "Kafka Manual Commit Factory", "group": "consumer (advanced)",
"label": "consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory",
"deprecated": false, "autowired": true, "secret": false, "description":
"Factory to use for creating KafkaManualCommit instances. This allows to plugin
a custom factory to create custom KafkaManualC [...]
"pollExceptionStrategy": { "index": 41, "kind": "property", "displayName":
"Poll Exception Strategy", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.PollExceptionStrategy", "deprecated": false,
"autowired": true, "secret": false, "description": "To use a custom strategy
with the consumer to control how to handle exceptions thrown from the Kafka
broker while pooling messages." },
"subscribeConsumerBackoffInterval": { "index": 42, "kind": "property",
"displayName": "Subscribe Consumer Backoff Interval", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 5000, "description": "The delay in millis
seconds to wait before trying again to subscribe to the kafka broker." },
- "subscribeConsumerBackoffMaxAttempts": { "index": 43, "kind": "property",
"displayName": "Subscribe Consumer Backoff Max Attempts", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "description": "Maximum number the kafka consumer will attempt
to subscribe to the kafka broker, before eventually giving up and failing.
Error during subscribing the consumer to [...]
+ "subscribeConsumerBackoffMaxAttempts": { "index": 43, "kind": "property",
"displayName": "Subscribe Consumer Backoff Max Attempts", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "description": "Maximum number the kafka consumer will attempt
to subscribe to the kafka broker, before eventually giving up and failing.
Error during subscribing the consumer to [...]
"batchWithIndividualHeaders": { "index": 44, "kind": "property",
"displayName": "Batch With Individual Headers", "group": "producer", "label":
"producer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "If this feature is enabled and a single
element of a batch [...]
"bufferMemorySize": { "index": 45, "kind": "property", "displayName":
"Buffer Memory Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "33554432",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The total bytes of
memory the producer can use to buffer records [...]
"compressionCodec": { "index": 46, "kind": "property", "displayName":
"Compression Codec", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "none",
"gzip", "snappy", "lz4", "zstd" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "none", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This parameter allo [...]
@@ -76,8 +76,8 @@
"key": { "index": 51, "kind": "property", "displayName": "Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The record key (or null if no key is
specified). If this option has been configured then it take precedence over
header Kaf [...]
"keySerializer": { "index": 52, "kind": "property", "displayName": "Key
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for key [...]
"lazyStartProducer": { "index": 53, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fai [...]
- "lingerMs": { "index": 54, "kind": "property", "displayName": "Linger Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions int [...]
- "maxBlockMs": { "index": 55, "kind": "property", "displayName": "Max Block
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor(), [...]
+ "lingerMs": { "index": 54, "kind": "property", "displayName": "Linger Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions int [...]
+ "maxBlockMs": { "index": 55, "kind": "property", "displayName": "Max Block
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor(), [...]
"maxInFlightRequest": { "index": 56, "kind": "property", "displayName":
"Max In Flight Request", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unacknowledged requests
the client will send [...]
"maxRequestSize": { "index": 57, "kind": "property", "displayName": "Max
Request Size", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1048576",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The maximum size of a
request. This is also effectively a cap on the m [...]
"metadataMaxAgeMs": { "index": 58, "kind": "property", "displayName":
"Metadata Max Age Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "300000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The period of time in
milliseconds after which we force a refresh [...]
@@ -86,7 +86,7 @@
"noOfMetricsSample": { "index": 61, "kind": "property", "displayName": "No
Of Metrics Sample", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of samples maintained to compute
metrics." },
"partitioner": { "index": 62, "kind": "property", "displayName":
"Partitioner", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The partitioner class
for [...]
"partitionKey": { "index": 63, "kind": "property", "displayName":
"Partition Key", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The partition to which the record will be sent
(or null if no partition was specified). If this option [...]
- "producerBatchSize": { "index": 64, "kind": "property", "displayName":
"Producer Batch Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "16384",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer req [...]
+ "producerBatchSize": { "index": 64, "kind": "property", "displayName":
"Producer Batch Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "16384",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer req [...]
"queueBufferingMaxMessages": { "index": 65, "kind": "property",
"displayName": "Queue Buffering Max Messages", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unsent messages that can
be [...]
"receiveBufferBytes": { "index": 66, "kind": "property", "displayName":
"Receive Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "65536",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP
receive buffer (SO_RCVBUF) to use when readi [...]
"reconnectBackoffMs": { "index": 67, "kind": "property", "displayName":
"Reconnect Backoff Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "50",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to reconnect to a give [...]
@@ -94,7 +94,7 @@
"requestRequiredAcks": { "index": 69, "kind": "property", "displayName":
"Request Required Acks", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1",
"0", "1" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "all", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of acknowledgments t [...]
"requestTimeoutMs": { "index": 70, "kind": "property", "displayName":
"Request Timeout Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
broker will wait trying to meet the request.r [...]
"retries": { "index": 71, "kind": "property", "displayName": "Retries",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record whose send fails with a potentially [...]
- "retryBackoffMs": { "index": 72, "kind": "property", "displayName": "Retry
Backoff Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "100",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Before each retry, the
producer refreshes the metadata of relevant topics [...]
+ "retryBackoffMs": { "index": 72, "kind": "property", "displayName": "Retry
Backoff Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "100",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Before each retry, the
producer refreshes the metadata of relevant topics [...]
"sendBufferBytes": { "index": 73, "kind": "property", "displayName": "Send
Buffer Bytes", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "131072",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Socket write buffer
size" },
"valueSerializer": { "index": 74, "kind": "property", "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.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for [...]
"workerPool": { "index": 75, "kind": "property", "displayName": "Worker
Pool", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "java.util.concurrent.ExecutorService", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknowl [...]
@@ -121,8 +121,8 @@
"sslEndpointAlgorithm": { "index": 96, "kind": "property", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serve [...]
"sslKeymanagerAlgorithm": { "index": 97, "kind": "property",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SSL [...]
"sslKeyPassword": { "index": 98, "kind": "property", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystore [...]
- "sslKeystoreLocation": { "index": 99, "kind": "property", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used fo [...]
- "sslKeystorePassword": { "index": 100, "kind": "property", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
+ "sslKeystoreLocation": { "index": 99, "kind": "property", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for the client and can be use [...]
+ "sslKeystorePassword": { "index": 100, "kind": "property", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for the client and onl [...]
"sslKeystoreType": { "index": 101, "kind": "property", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
"sslProtocol": { "index": 102, "kind": "property", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
"sslProvider": { "index": 103, "kind": "property", "displayName": "Ssl
Provider", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the security provider used for SSL
connections. Default value is the default security [...]
@@ -159,7 +159,7 @@
"autoCommitEnable": { "index": 8, "kind": "parameter", "displayName":
"Auto Commit Enable", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "If true, periodically
commit to ZooKeeper the offset of messages already fetched [...]
"autoCommitIntervalMs": { "index": 9, "kind": "parameter", "displayName":
"Auto Commit Interval Ms", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"5000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The frequency in ms that the consumer offsets
are committed [...]
"autoOffsetReset": { "index": 10, "kind": "parameter", "displayName":
"Auto Offset Reset", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "latest",
"earliest", "none" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "latest", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "What to do when there is no [...]
- "breakOnFirstError": { "index": 11, "kind": "parameter", "displayName":
"Break On First Error", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This options controls
what happens when a consumer is processing an exchange [...]
+ "breakOnFirstError": { "index": 11, "kind": "parameter", "displayName":
"Break On First Error", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This options controls
what happens when a consumer is processing an exchange [...]
"checkCrcs": { "index": 12, "kind": "parameter", "displayName": "Check
Crcs", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Automatically check the CRC32 of the records
consumed. This ensures no on-the-wire [...]
"commitTimeoutMs": { "index": 13, "kind": "parameter", "displayName":
"Commit Timeout Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The maximum time, in
milliseconds, that the code will wait for a synchro [...]
"consumerRequestTimeoutMs": { "index": 14, "kind": "parameter",
"displayName": "Consumer Request Timeout Ms", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "40000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls the maximum amount
of t [...]
@@ -171,7 +171,7 @@
"groupInstanceId": { "index": 20, "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.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A unique identifier of the consumer instance
provided by the end user. Only non-empty strings ar [...]
"headerDeserializer": { "index": 21, "kind": "parameter", "displayName":
"Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to de
[...]
"heartbeatIntervalMs": { "index": 22, "kind": "parameter", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "3000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinat [...]
- "keyDeserializer": { "index": 23, "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.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class fo
[...]
+ "keyDeserializer": { "index": 23, "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.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class fo
[...]
"maxPartitionFetchBytes": { "index": 24, "kind": "parameter",
"displayName": "Max Partition Fetch Bytes", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server [...]
"maxPollIntervalMs": { "index": 25, "kind": "parameter", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. Th [...]
"maxPollRecords": { "index": 26, "kind": "parameter", "displayName": "Max
Poll Records", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "500",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll()" },
@@ -179,7 +179,7 @@
"partitionAssignor": { "index": 28, "kind": "parameter", "displayName":
"Partition Assignor", "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.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The class name of the part [...]
"pollOnError": { "index": 29, "kind": "parameter", "displayName": "Poll On
Error", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [
"DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "ERROR_HANDLER",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "confi [...]
"pollTimeoutMs": { "index": 30, "kind": "parameter", "displayName": "Poll
Timeout Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used when
polling the KafkaConsumer." },
- "seekTo": { "index": 31, "kind": "parameter", "displayName": "Seek To",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.kafka.SeekPolicy", "enum": [
"BEGINNING", "END" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end on [...]
+ "seekTo": { "index": 31, "kind": "parameter", "displayName": "Seek To",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.kafka.SeekPolicy", "enum": [
"BEGINNING", "END" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from the beginning or the [...]
"sessionTimeoutMs": { "index": 32, "kind": "parameter", "displayName":
"Session Timeout Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect failures when using Kafka's group manage [...]
"specificAvroReader": { "index": 33, "kind": "parameter", "displayName":
"Specific Avro Reader", "group": "consumer", "label": "confluent,consumer",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This enables the use of
a specific Avro reader for use with the C [...]
"topicIsPattern": { "index": 34, "kind": "parameter", "displayName":
"Topic Is Pattern", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Whether the topic is a
pattern (regular expression). This can be used to subscribe [...]
@@ -198,8 +198,8 @@
"headerSerializer": { "index": 47, "kind": "parameter", "displayName":
"Header Serializer", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderSerializer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderSerializer to
serialize [...]
"key": { "index": 48, "kind": "parameter", "displayName": "Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The record key (or null if no key is
specified). If this option has been configured then it take precedence over
header Ka [...]
"keySerializer": { "index": 49, "kind": "parameter", "displayName": "Key
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for ke [...]
- "lingerMs": { "index": 50, "kind": "parameter", "displayName": "Linger
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions in [...]
- "maxBlockMs": { "index": 51, "kind": "parameter", "displayName": "Max
Block Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor() [...]
+ "lingerMs": { "index": 50, "kind": "parameter", "displayName": "Linger
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions in [...]
+ "maxBlockMs": { "index": 51, "kind": "parameter", "displayName": "Max
Block Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor() [...]
"maxInFlightRequest": { "index": 52, "kind": "parameter", "displayName":
"Max In Flight Request", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unacknowledged requests
the client will send [...]
"maxRequestSize": { "index": 53, "kind": "parameter", "displayName": "Max
Request Size", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1048576",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The maximum size of a
request. This is also effectively a cap on the [...]
"metadataMaxAgeMs": { "index": 54, "kind": "parameter", "displayName":
"Metadata Max Age Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "300000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The period of time in
milliseconds after which we force a refresh [...]
@@ -208,7 +208,7 @@
"noOfMetricsSample": { "index": 57, "kind": "parameter", "displayName":
"No Of Metrics Sample", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "2", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of samples maintained to compute
metrics." },
"partitioner": { "index": 58, "kind": "parameter", "displayName":
"Partitioner", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The partitioner class fo
[...]
"partitionKey": { "index": 59, "kind": "parameter", "displayName":
"Partition Key", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The partition to which the record will be sent
(or null if no partition was specified). If this optio [...]
- "producerBatchSize": { "index": 60, "kind": "parameter", "displayName":
"Producer Batch Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "16384",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer re [...]
+ "producerBatchSize": { "index": 60, "kind": "parameter", "displayName":
"Producer Batch Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "16384",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer re [...]
"queueBufferingMaxMessages": { "index": 61, "kind": "parameter",
"displayName": "Queue Buffering Max Messages", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unsent messages that can
b [...]
"receiveBufferBytes": { "index": 62, "kind": "parameter", "displayName":
"Receive Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "65536",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP
receive buffer (SO_RCVBUF) to use when read [...]
"reconnectBackoffMs": { "index": 63, "kind": "parameter", "displayName":
"Reconnect Backoff Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "50",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to reconnect to a giv [...]
@@ -216,7 +216,7 @@
"requestRequiredAcks": { "index": 65, "kind": "parameter", "displayName":
"Request Required Acks", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1",
"0", "1" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "all", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of acknowledgments [...]
"requestTimeoutMs": { "index": 66, "kind": "parameter", "displayName":
"Request Timeout Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time the
broker will wait trying to meet the request. [...]
"retries": { "index": 67, "kind": "parameter", "displayName": "Retries",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record whose send fails with a potentially [...]
- "retryBackoffMs": { "index": 68, "kind": "parameter", "displayName":
"Retry Backoff Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "100",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Before each retry, the
producer refreshes the metadata of relevant topics [...]
+ "retryBackoffMs": { "index": 68, "kind": "parameter", "displayName":
"Retry Backoff Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "100",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Before each retry, the
producer refreshes the metadata of relevant topics [...]
"sendBufferBytes": { "index": 69, "kind": "parameter", "displayName":
"Send Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "131072",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Socket write buffer
size" },
"valueSerializer": { "index": 70, "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.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class fo [...]
"workerPool": { "index": 71, "kind": "parameter", "displayName": "Worker
Pool", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "java.util.concurrent.ExecutorService", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknow [...]
@@ -243,8 +243,8 @@
"sslEndpointAlgorithm": { "index": 92, "kind": "parameter", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serv [...]
"sslKeymanagerAlgorithm": { "index": 93, "kind": "parameter",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SS [...]
"sslKeyPassword": { "index": 94, "kind": "parameter", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystor [...]
- "sslKeystoreLocation": { "index": 95, "kind": "parameter", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used f [...]
- "sslKeystorePassword": { "index": 96, "kind": "parameter", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
+ "sslKeystoreLocation": { "index": 95, "kind": "parameter", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for the client and can be us [...]
+ "sslKeystorePassword": { "index": 96, "kind": "parameter", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for the client and onl [...]
"sslKeystoreType": { "index": 97, "kind": "parameter", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
"sslProtocol": { "index": 98, "kind": "parameter", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
"sslProvider": { "index": 99, "kind": "parameter", "displayName": "Ssl
Provider", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the security provider used for SSL
connections. Default value is the default security [...]
diff --git a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
index 98c82ea284b..328cf78233f 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
@@ -64,7 +64,7 @@
{
"name": "camel.component.kafka.break-on-first-error",
"type": "java.lang.Boolean",
- "description": "This options controls what happens when a consumer is
processing an exchange and it fails. If the option is false then the consumer
continues to the next message and processes it. If the option is true then the
consumer breaks out, and will seek back to offset of the message that caused a
failure, and then re-attempt to process this message. However this can lead to
endless processing of the same message if its bound to fail every time, eg a
poison message. Therefor [...]
+ "description": "This options controls what happens when a consumer is
processing an exchange and it fails. If the option is false then the consumer
continues to the next message and processes it. If the option is true then the
consumer breaks out, and will seek back to offset of the message that caused a
failure, and then re-attempt to process this message. However this can lead to
endless processing of the same message if its bound to fail every time, eg a
poison message. Therefor [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": false
},
@@ -152,7 +152,7 @@
{
"name": "camel.component.kafka.create-consumer-backoff-max-attempts",
"type": "java.lang.Integer",
- "description": "Maximum attempts to create the kafka consumer
(kafka-client), before eventually giving up and failing. Error during creating
the consumer may be fatal due to invalid configuration and as such recovery is
not possible. However, one part of the validation is DNS resolution of the
bootstrap broker hostnames. This may be a temporary networking problem, and
could potentially be recoverable. While other errors are fatal such as some
invalid kafka configurations. Unfortuna [...]
+ "description": "Maximum attempts to create the kafka consumer
(kafka-client), before eventually giving up and failing. Error during creating
the consumer may be fatal due to invalid configuration and as such recovery is
not possible. However, one part of the validation is DNS resolution of the
bootstrap broker hostnames. This may be a temporary networking problem, and
could potentially be recoverable. While other errors are fatal, such as some
invalid kafka configurations. Unfortun [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
},
{
@@ -311,7 +311,7 @@
{
"name": "camel.component.kafka.key-deserializer",
"type": "java.lang.String",
- "description": "Deserializer class for key that implements the
Deserializer interface.",
+ "description": "Deserializer class for the key that implements the
Deserializer interface.",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer"
},
@@ -332,14 +332,14 @@
{
"name": "camel.component.kafka.linger-ms",
"type": "java.lang.Integer",
- "description": "The producer groups together any records that arrive in
between request transmissions into a single batched request. Normally this
occurs only under load when records arrive faster than they can be sent out.
However in some circumstances the client may want to reduce the number of
requests even under moderate load. This setting accomplishes this by adding a
small amount of artificial delay that is, rather than immediately sending out a
record the producer will wait [...]
+ "description": "The producer groups together any records that arrive in
between request transmissions into a single batched request. Normally this
occurs only under load when records arrive faster than they can be sent out.
However in some circumstances the client may want to reduce the number of
requests even under moderate load. This setting accomplishes this by adding a
small amount of artificial delay that is, rather than immediately sending out a
record the producer will wait [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": 0
},
{
"name": "camel.component.kafka.max-block-ms",
"type": "java.lang.Integer",
- "description": "The configuration controls how long the KafkaProducer's
send(), partitionsFor(), initTransactions(), sendOffsetsToTransaction(),
commitTransaction() and abortTransaction() methods will block. For send() this
timeout bounds the total time waiting for both metadata fetch and buffer
allocation (blocking in the user-supplied serializers or partitioner is not
counted against this timeout). For partitionsFor() this timeout bounds the time
spent waiting for metadata if it [...]
+ "description": "The configuration controls how long the KafkaProducer's
send(), partitionsFor(), initTransactions(), sendOffsetsToTransaction(),
commitTransaction() and abortTransaction() methods will block. For send() this
timeout bounds the total time waiting for both metadata fetch and buffer
allocation (blocking in the user-supplied serializers or partitioner is not
counted against this timeout). For partitionsFor() this timeout bounds the time
spent waiting for metadata if it [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": 60000
},
@@ -452,7 +452,7 @@
{
"name": "camel.component.kafka.producer-batch-size",
"type": "java.lang.Integer",
- "description": "The producer will attempt to batch records together into
fewer requests whenever multiple records are being sent to the same partition.
This helps performance on both the client and the server. This configuration
controls the default batch size in bytes. No attempt will be made to batch
records larger than this size.Requests sent to brokers will contain multiple
batches, one for each partition with data available to be sent.A small batch
size will make batching less [...]
+ "description": "The producer will attempt to batch records together into
fewer requests whenever multiple records are being sent to the same partition.
This helps performance on both the client and the server. This configuration
controls the default batch size in bytes. No attempt will be made to batch
records larger than this size. Requests sent to brokers will contain multiple
batches, one for each partition with data available to be sent. A small batch
size will make batching le [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": 16384
},
@@ -514,7 +514,7 @@
{
"name": "camel.component.kafka.retry-backoff-ms",
"type": "java.lang.Integer",
- "description": "Before each retry, the producer refreshes the metadata
of relevant topics to see if a new leader has been elected. Since leader
election takes a bit of time, this property specifies the amount of time that
the producer waits before refreshing the metadata.",
+ "description": "Before each retry, the producer refreshes the metadata
of relevant topics to see if a new leader has been elected. Since the leader
election takes a bit of time, this property specifies the amount of time that
the producer waits before refreshing the metadata.",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": 100
},
@@ -553,7 +553,7 @@
{
"name": "camel.component.kafka.seek-to",
"type": "org.apache.camel.component.kafka.SeekPolicy",
- "description": "Set if KafkaConsumer will read from beginning or end on
startup: SeekPolicy.BEGINNING: read from beginning. SeekPolicy.END: read from
end.",
+ "description": "Set if KafkaConsumer will read from the beginning or the
end on startup: SeekPolicy.BEGINNING: read from the beginning. SeekPolicy.END:
read from the end.",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
},
{
@@ -625,13 +625,13 @@
{
"name": "camel.component.kafka.ssl-keystore-location",
"type": "java.lang.String",
- "description": "The location of the key store file. This is optional for
client and can be used for two-way authentication for client.",
+ "description": "The location of the key store file. This is optional for
the client and can be used for two-way authentication for the client.",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
},
{
"name": "camel.component.kafka.ssl-keystore-password",
"type": "java.lang.String",
- "description": "The store password for the key store file. This is
optional for client and only needed if sslKeystoreLocation' is configured. Key
store password is not supported for PEM format.",
+ "description": "The store password for the key store file. This is
optional for the client and only needed if sslKeystoreLocation' is configured.
Key store password is not supported for PEM format.",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
},
{
@@ -689,7 +689,7 @@
{
"name": "camel.component.kafka.subscribe-consumer-backoff-max-attempts",
"type": "java.lang.Integer",
- "description": "Maximum number the kafka consumer will attempt to
subscribe to the kafka broker, before eventually giving up and failing. Error
during subscribing the consumer to the kafka topic could be temporary errors
due to network issues, and could potentially be recoverable. Camel will by
default retry forever, and therefore never give up. If you want to give up
after many attempts then set this option and Camel will then when giving up
terminate the consumer. You can manuall [...]
+ "description": "Maximum number the kafka consumer will attempt to
subscribe to the kafka broker, before eventually giving up and failing. Error
during subscribing the consumer to the kafka topic could be temporary errors
due to network issues, and could potentially be recoverable. Camel will by
default retry forever, and therefore never give up. If you want to give up
after many attempts, then set this option and Camel will then when giving up
terminate the consumer. You can manual [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
},
{
diff --git
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index 79b5a08eb1d..59372ccc4d1 100644
---
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -124,7 +124,7 @@ public class KafkaComponentConfiguration
* consumer breaks out, and will seek back to offset of the message that
* caused a failure, and then re-attempt to process this message. However
* this can lead to endless processing of the same message if its bound to
- * fail every time, eg a poison message. Therefore its recommended to deal
+ * fail every time, eg a poison message. Therefore it is recommended to
deal
* with that for example by using Camel's error handler.
*/
private Boolean breakOnFirstError = false;
@@ -218,7 +218,8 @@ public class KafkaComponentConfiguration
*/
private Integer heartbeatIntervalMs = 3000;
/**
- * Deserializer class for key that implements the Deserializer interface.
+ * Deserializer class for the key that implements the Deserializer
+ * interface.
*/
private String keyDeserializer =
"org.apache.kafka.common.serialization.StringDeserializer";
/**
@@ -276,8 +277,9 @@ public class KafkaComponentConfiguration
*/
private Long pollTimeoutMs = 5000L;
/**
- * Set if KafkaConsumer will read from beginning or end on startup:
- * SeekPolicy.BEGINNING: read from beginning. SeekPolicy.END: read from
end.
+ * Set if KafkaConsumer will read from the beginning or the end on startup:
+ * SeekPolicy.BEGINNING: read from the beginning. SeekPolicy.END: read from
+ * the end.
*/
private SeekPolicy seekTo;
/**
@@ -312,13 +314,13 @@ public class KafkaComponentConfiguration
* be fatal due to invalid configuration and as such recovery is not
* possible. However, one part of the validation is DNS resolution of the
* bootstrap broker hostnames. This may be a temporary networking problem,
- * and could potentially be recoverable. While other errors are fatal such
- * as some invalid kafka configurations. Unfortunately kafka-client does
not
- * separate this kind of errors. Camel will by default retry forever, and
- * therefore never give up. If you want to give up after many attempts then
- * set this option and Camel will then when giving up terminate the
- * consumer. You can manually restart the consumer by stopping and starting
- * the route, to try again.
+ * and could potentially be recoverable. While other errors are fatal, such
+ * as some invalid kafka configurations. Unfortunately, kafka-client does
+ * not separate this kind of errors. Camel will by default retry forever,
+ * and therefore never give up. If you want to give up after many attempts
+ * then set this option and Camel will then when giving up terminate the
+ * consumer. To try again, you can manually restart the consumer by
+ * stopping, and starting the route.
*/
private Integer createConsumerBackoffMaxAttempts;
/**
@@ -363,7 +365,7 @@ public class KafkaComponentConfiguration
* the consumer to the kafka topic could be temporary errors due to network
* issues, and could potentially be recoverable. Camel will by default
retry
* forever, and therefore never give up. If you want to give up after many
- * attempts then set this option and Camel will then when giving up
+ * attempts, then set this option and Camel will then when giving up
* terminate the consumer. You can manually restart the consumer by
stopping
* and starting the route, to try again.
*/
@@ -455,16 +457,16 @@ public class KafkaComponentConfiguration
* requests even under moderate load. This setting accomplishes this by
* adding a small amount of artificial delay that is, rather than
* immediately sending out a record the producer will wait for up to the
- * given delay to allow other records to be sent so that the sends can be
- * batched together. This can be thought of as analogous to Nagle's
- * algorithm in TCP. This setting gives the upper bound on the delay for
- * batching: once we get batch.size worth of records for a partition it
will
- * be sent immediately regardless of this setting, however if we have fewer
- * than this many bytes accumulated for this partition we will 'linger' for
- * the specified time waiting for more records to show up. This setting
- * defaults to 0 (i.e. no delay). Setting linger.ms=5, for example, would
- * have the effect of reducing the number of requests sent but would add up
- * to 5ms of latency to records sent in the absense of load.
+ * given delay to allow other records to be sent so that they can be
batched
+ * together. This can be thought of as analogous to Nagle's algorithm in
+ * TCP. This setting gives the upper bound on the delay for batching: once
+ * we get batch.size worth of records for a partition it will be sent
+ * immediately regardless of this setting, however if we have fewer than
+ * this many bytes accumulated for this partition we will 'linger' for the
+ * specified time waiting for more records to show up. This setting
defaults
+ * to 0 (i.e. no delay). Setting linger.ms=5, for example, would have the
+ * effect of reducing the number of requests sent but would add up to 5ms
of
+ * latency to records sent in the absense of load.
*/
private Integer lingerMs = 0;
/**
@@ -475,8 +477,8 @@ public class KafkaComponentConfiguration
* buffer allocation (blocking in the user-supplied serializers or
* partitioner is not counted against this timeout). For partitionsFor()
* this timeout bounds the time spent waiting for metadata if it is
- * unavailable. The transaction-related methods always block, but may
- * timeout if the transaction coordinator could not be discovered or did
not
+ * unavailable. The transaction-related methods always block, but may time
+ * out if the transaction coordinator could not be discovered or did not
* respond within the timeout.
*/
private Integer maxBlockMs = 60000;
@@ -532,12 +534,13 @@ public class KafkaComponentConfiguration
* whenever multiple records are being sent to the same partition. This
* helps performance on both the client and the server. This configuration
* controls the default batch size in bytes. No attempt will be made to
- * batch records larger than this size.Requests sent to brokers will
contain
- * multiple batches, one for each partition with data available to be
sent.A
- * small batch size will make batching less common and may reduce
throughput
- * (a batch size of zero will disable batching entirely). A very large
batch
- * size may use memory a bit more wastefully as we will always allocate a
- * buffer of the specified batch size in anticipation of additional
records.
+ * batch records larger than this size. Requests sent to brokers will
+ * contain multiple batches, one for each partition with data available to
+ * be sent. A small batch size will make batching less common and may
reduce
+ * throughput (a batch size of zero will disable batching entirely). A very
+ * large batch size may use memory a bit more wastefully as we will always
+ * allocate a buffer of the specified batch size in anticipation of
+ * additional records.
*/
private Integer producerBatchSize = 16384;
/**
@@ -613,9 +616,9 @@ public class KafkaComponentConfiguration
private Integer retries;
/**
* Before each retry, the producer refreshes the metadata of relevant
topics
- * to see if a new leader has been elected. Since leader election takes a
- * bit of time, this property specifies the amount of time that the
producer
- * waits before refreshing the metadata.
+ * to see if a new leader has been elected. Since the leader election takes
+ * a bit of time, this property specifies the amount of time that the
+ * producer waits before refreshing the metadata.
*/
private Integer retryBackoffMs = 100;
/**
@@ -784,14 +787,14 @@ public class KafkaComponentConfiguration
*/
private String sslKeyPassword;
/**
- * The location of the key store file. This is optional for client and can
- * be used for two-way authentication for client.
+ * The location of the key store file. This is optional for the client and
+ * can be used for two-way authentication for the client.
*/
private String sslKeystoreLocation;
/**
- * The store password for the key store file. This is optional for client
- * and only needed if sslKeystoreLocation' is configured. Key store
password
- * is not supported for PEM format.
+ * The store password for the key store file. This is optional for the
+ * client and only needed if sslKeystoreLocation' is configured. Key store
+ * password is not supported for PEM format.
*/
private String sslKeystorePassword;
/**
