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.git
The following commit(s) were added to refs/heads/main by this push:
new 37558f66bba Regen
37558f66bba is described below
commit 37558f66bba2cb3e117cc2d9b870231976eadab2
Author: Claus Ibsen <[email protected]>
AuthorDate: Tue Jul 11 06:41:13 2023 +0200
Regen
---
.../org/apache/camel/catalog/components/kafka.json | 40 +++++++++++-----------
.../org/apache/camel/component/kafka/kafka.json | 40 +++++++++++-----------
2 files changed, 40 insertions(+), 40 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
index c5a3fb81366..6d05755c43b 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/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/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
b/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
index c5a3fb81366..6d05755c43b 100644
---
a/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
+++
b/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/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 [...]