This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new aa579dc1b76 Regen
aa579dc1b76 is described below
commit aa579dc1b760d23f2f5fbcdca8cdfe62c74d2b22
Author: Claus Ibsen <[email protected]>
AuthorDate: Sat Feb 22 07:49:48 2025 +0100
Regen
---
.../camel/springboot/catalog/components/kafka.json | 137 +++++++++++----------
.../camel-kafka-starter/src/main/docs/kafka.json | 7 ++
.../springboot/KafkaComponentConfiguration.java | 20 +++
3 files changed, 96 insertions(+), 68 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
index e90dffbb0fb..117e3f3dddd 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
@@ -73,74 +73,75 @@
"pollExceptionStrategy": { "index": 46, "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": 47, "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": 48, "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": 49, "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": 50, "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": 51, "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 [...]
- "connectionMaxIdleMs": { "index": 52, "kind": "property", "displayName":
"Connection Max Idle Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "540000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Close idle connections
after the number of milliseconds spec [...]
- "deliveryTimeoutMs": { "index": 53, "kind": "property", "displayName":
"Delivery Timeout Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "120000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "An upper bound on the
time to report success or failure after a c [...]
- "enableIdempotence": { "index": 54, "kind": "property", "displayName":
"Enable Idempotence", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "When set to 'true', the
producer will ensure that exactly one copy of each messa [...]
- "headerSerializer": { "index": 55, "kind": "property", "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 k [...]
- "key": { "index": 56, "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": 57, "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": 58, "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": 59, "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": 60, "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": 61, "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": 62, "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": 63, "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 [...]
- "metricReporters": { "index": 64, "kind": "property", "displayName":
"Metric Reporters", "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": "A list of classes to use as metrics reporters.
Implementing the MetricReporter interface allows pl [...]
- "metricsSampleWindowMs": { "index": 65, "kind": "property", "displayName":
"Metrics Sample Window 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 window of time a metrics sample is
computed over." },
- "noOfMetricsSample": { "index": 66, "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": 67, "kind": "property", "displayName":
"Partitioner", "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 partitioner class for partitioning
messages amongst sub-topics. The default partitioner is based on the [...]
- "partitionerIgnoreKeys": { "index": 68, "kind": "property", "displayName":
"Partitioner Ignore Keys", "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": "Whether the message keys
should be ignored when computing the partitio [...]
- "partitionKey": { "index": 69, "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": 70, "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": 71, "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": 72, "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": 73, "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 [...]
- "recordMetadata": { "index": 74, "kind": "property", "displayName":
"Record Metadata", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the producer should store the
RecordMetadata results from sending to Kafka. Th [...]
- "requestRequiredAcks": { "index": 75, "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": 76, "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": 77, "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 that has failed to be sent due to a [...]
- "sendBufferBytes": { "index": 78, "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" },
- "useIterator": { "index": 79, "kind": "property", "displayName": "Use
Iterator", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether sending to kafka should send the
message body as a single record, or use a java [...]
- "valueSerializer": { "index": 80, "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": 81, "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 [...]
- "workerPoolCoreSize": { "index": 82, "kind": "property", "displayName":
"Worker Pool Core Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Number of core threads
for the worker pool for continue routing Ex [...]
- "workerPoolMaxSize": { "index": 83, "kind": "property", "displayName":
"Worker Pool Max Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "20",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads for the worker pool for continue routing E [...]
- "autowiredEnabled": { "index": 84, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
- "kafkaClientFactory": { "index": 85, "kind": "property", "displayName":
"Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false,
"autowired": true, "secret": false, "description": "Factory to use for creating
org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances. This allows
configuring a custom f [...]
- "synchronous": { "index": 86, "kind": "property", "displayName":
"Synchronous", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether synchronous processing should be
strictly used" },
- "healthCheckConsumerEnabled": { "index": 87, "kind": "property",
"displayName": "Health Check Consumer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all consumer based health checks
from this component" },
- "healthCheckProducerEnabled": { "index": 88, "kind": "property",
"displayName": "Health Check Producer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all producer based health checks
from this component. Notice: Camel has by default disabled all producer based
health-checks. You can turn on produce [...]
- "interceptorClasses": { "index": 89, "kind": "property", "displayName":
"Interceptor Classes", "group": "monitoring", "label": "common,monitoring",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets interceptors for producer or consumers.
Producer interceptors have to be cla [...]
- "schemaRegistryURL": { "index": 90, "kind": "property", "displayName":
"Schema Registry URL", "group": "schema", "label": "schema", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "URL of the schema registry servers to use. The
format is host1:port1,host2:port2. This is known a [...]
- "kerberosBeforeReloginMinTime": { "index": 91, "kind": "property",
"displayName": "Kerberos Before Relogin Min Time", "group": "security",
"label": "common,security", "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": "Login thread sleep time between ref [...]
- "kerberosConfigLocation": { "index": 92, "kind": "property",
"displayName": "Kerberos Config 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": "Location of the kerberos
config file." },
- "kerberosInitCmd": { "index": 93, "kind": "property", "displayName":
"Kerberos Init Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Kerberos kinit command path. Default is
\/usr\/bin\/k [...]
- "kerberosPrincipalToLocalRules": { "index": 94, "kind": "property",
"displayName": "Kerberos Principal To Local Rules", "group": "security",
"label": "common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "DEFAULT", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of rules for mapping from [...]
- "kerberosRenewJitter": { "index": 95, "kind": "property", "displayName":
"Kerberos Renew Jitter", "group": "security", "label": "common,security",
"required": false, "type": "number", "javaType": "java.lang.Double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"0.05", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Percentage of random jitter added to the
renewal time." },
- "kerberosRenewWindowFactor": { "index": 96, "kind": "property",
"displayName": "Kerberos Renew Window Factor", "group": "security", "label":
"common,security", "required": false, "type": "number", "javaType":
"java.lang.Double", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0.8", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Login thread will sleep until the specified wi
[...]
- "saslJaasConfig": { "index": 97, "kind": "property", "displayName": "Sasl
Jaas Config", "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": "Expose the kafka sasl.jaas.config parameter
Example: org.apache.kafka.common.security.plain.P [...]
- "saslKerberosServiceName": { "index": 98, "kind": "property",
"displayName": "Sasl Kerberos Service Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be defined eithe [...]
- "saslMechanism": { "index": 99, "kind": "property", "displayName": "Sasl
Mechanism", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "GSSAPI",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The Simple
Authentication and Security Layer (SASL) Mechanism used. F [...]
- "securityProtocol": { "index": 100, "kind": "property", "displayName":
"Security Protocol", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PLAINTEXT", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Protocol used to communicate with brokers.
SASL_PLAINTEXT, [...]
- "sslCipherSuites": { "index": 101, "kind": "property", "displayName": "Ssl
Cipher Suites", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of cipher suites. This is a named
combination of authentication, encryption, MAC a [...]
- "sslContextParameters": { "index": 102, "kind": "property", "displayName":
"Ssl Context Parameters", "group": "security", "label": "common,security",
"required": false, "type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "SSL configuration using a Camel SSLContextPar
[...]
- "sslEnabledProtocols": { "index": 103, "kind": "property", "displayName":
"Ssl Enabled Protocols", "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 list of protocols enabled for SSL
connections. The default is TLSv1.2,TLSv1.3 [...]
- "sslEndpointAlgorithm": { "index": 104, "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 serv [...]
- "sslKeymanagerAlgorithm": { "index": 105, "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
SS [...]
- "sslKeyPassword": { "index": 106, "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 sslKeystor [...]
- "sslKeystoreLocation": { "index": 107, "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 us [...]
- "sslKeystorePassword": { "index": 108, "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": 109, "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 the cl [...]
- "sslProtocol": { "index": 110, "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": 111, "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 [...]
- "sslTrustmanagerAlgorithm": { "index": 112, "kind": "property",
"displayName": "Ssl Trustmanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "PKIX", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by trust manager factory
for [...]
- "sslTruststoreLocation": { "index": 113, "kind": "property",
"displayName": "Ssl Truststore 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
trust store file." },
- "sslTruststorePassword": { "index": 114, "kind": "property",
"displayName": "Ssl Truststore 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 for the
trust store file. If a password is not set, trust store f [...]
- "sslTruststoreType": { "index": 115, "kind": "property", "displayName":
"Ssl Truststore 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 trust store file. The
default value is [...]
- "useGlobalSslContextParameters": { "index": 116, "kind": "property",
"displayName": "Use Global Ssl Context Parameters", "group": "security",
"label": "security", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Enable usage of global SSL context
parameters." }
+ "subscribeConsumerTopicMustExists": { "index": 49, "kind": "property",
"displayName": "Subscribe Consumer Topic Must Exists", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether when a Camel
Kafka consumer is subscribing to a Kafka broker then check whether a topic
already exist on the broker, and fail if it do [...]
+ "batchWithIndividualHeaders": { "index": 50, "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": 51, "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": 52, "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 [...]
+ "connectionMaxIdleMs": { "index": 53, "kind": "property", "displayName":
"Connection Max Idle Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "540000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Close idle connections
after the number of milliseconds spec [...]
+ "deliveryTimeoutMs": { "index": 54, "kind": "property", "displayName":
"Delivery Timeout Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "120000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "An upper bound on the
time to report success or failure after a c [...]
+ "enableIdempotence": { "index": 55, "kind": "property", "displayName":
"Enable Idempotence", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "When set to 'true', the
producer will ensure that exactly one copy of each messa [...]
+ "headerSerializer": { "index": 56, "kind": "property", "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 k [...]
+ "key": { "index": 57, "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": 58, "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": 59, "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": 60, "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": 61, "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": 62, "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": 63, "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": 64, "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 [...]
+ "metricReporters": { "index": 65, "kind": "property", "displayName":
"Metric Reporters", "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": "A list of classes to use as metrics reporters.
Implementing the MetricReporter interface allows pl [...]
+ "metricsSampleWindowMs": { "index": 66, "kind": "property", "displayName":
"Metrics Sample Window 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 window of time a metrics sample is
computed over." },
+ "noOfMetricsSample": { "index": 67, "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": 68, "kind": "property", "displayName":
"Partitioner", "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 partitioner class for partitioning
messages amongst sub-topics. The default partitioner is based on the [...]
+ "partitionerIgnoreKeys": { "index": 69, "kind": "property", "displayName":
"Partitioner Ignore Keys", "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": "Whether the message keys
should be ignored when computing the partitio [...]
+ "partitionKey": { "index": 70, "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": 71, "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": 72, "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": 73, "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": 74, "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 [...]
+ "recordMetadata": { "index": 75, "kind": "property", "displayName":
"Record Metadata", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the producer should store the
RecordMetadata results from sending to Kafka. Th [...]
+ "requestRequiredAcks": { "index": 76, "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": 77, "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": 78, "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 that has failed to be sent due to a [...]
+ "sendBufferBytes": { "index": 79, "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" },
+ "useIterator": { "index": 80, "kind": "property", "displayName": "Use
Iterator", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether sending to kafka should send the
message body as a single record, or use a java [...]
+ "valueSerializer": { "index": 81, "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": 82, "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 [...]
+ "workerPoolCoreSize": { "index": 83, "kind": "property", "displayName":
"Worker Pool Core Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Number of core threads
for the worker pool for continue routing Ex [...]
+ "workerPoolMaxSize": { "index": 84, "kind": "property", "displayName":
"Worker Pool Max Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "20",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads for the worker pool for continue routing E [...]
+ "autowiredEnabled": { "index": 85, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
+ "kafkaClientFactory": { "index": 86, "kind": "property", "displayName":
"Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false,
"autowired": true, "secret": false, "description": "Factory to use for creating
org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances. This allows
configuring a custom f [...]
+ "synchronous": { "index": 87, "kind": "property", "displayName":
"Synchronous", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether synchronous processing should be
strictly used" },
+ "healthCheckConsumerEnabled": { "index": 88, "kind": "property",
"displayName": "Health Check Consumer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all consumer based health checks
from this component" },
+ "healthCheckProducerEnabled": { "index": 89, "kind": "property",
"displayName": "Health Check Producer Enabled", "group": "health", "label":
"health", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Used for enabling or disabling all producer based health checks
from this component. Notice: Camel has by default disabled all producer based
health-checks. You can turn on produce [...]
+ "interceptorClasses": { "index": 90, "kind": "property", "displayName":
"Interceptor Classes", "group": "monitoring", "label": "common,monitoring",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets interceptors for producer or consumers.
Producer interceptors have to be cla [...]
+ "schemaRegistryURL": { "index": 91, "kind": "property", "displayName":
"Schema Registry URL", "group": "schema", "label": "schema", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "URL of the schema registry servers to use. The
format is host1:port1,host2:port2. This is known a [...]
+ "kerberosBeforeReloginMinTime": { "index": 92, "kind": "property",
"displayName": "Kerberos Before Relogin Min Time", "group": "security",
"label": "common,security", "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": "Login thread sleep time between ref [...]
+ "kerberosConfigLocation": { "index": 93, "kind": "property",
"displayName": "Kerberos Config 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": "Location of the kerberos
config file." },
+ "kerberosInitCmd": { "index": 94, "kind": "property", "displayName":
"Kerberos Init Cmd", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"\/usr\/bin\/kinit", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Kerberos kinit command path. Default is
\/usr\/bin\/k [...]
+ "kerberosPrincipalToLocalRules": { "index": 95, "kind": "property",
"displayName": "Kerberos Principal To Local Rules", "group": "security",
"label": "common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "DEFAULT", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of rules for mapping from [...]
+ "kerberosRenewJitter": { "index": 96, "kind": "property", "displayName":
"Kerberos Renew Jitter", "group": "security", "label": "common,security",
"required": false, "type": "number", "javaType": "java.lang.Double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"0.05", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Percentage of random jitter added to the
renewal time." },
+ "kerberosRenewWindowFactor": { "index": 97, "kind": "property",
"displayName": "Kerberos Renew Window Factor", "group": "security", "label":
"common,security", "required": false, "type": "number", "javaType":
"java.lang.Double", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0.8", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Login thread will sleep until the specified wi
[...]
+ "saslJaasConfig": { "index": 98, "kind": "property", "displayName": "Sasl
Jaas Config", "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": "Expose the kafka sasl.jaas.config parameter
Example: org.apache.kafka.common.security.plain.P [...]
+ "saslKerberosServiceName": { "index": 99, "kind": "property",
"displayName": "Sasl Kerberos Service Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be defined eithe [...]
+ "saslMechanism": { "index": 100, "kind": "property", "displayName": "Sasl
Mechanism", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "GSSAPI",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The Simple
Authentication and Security Layer (SASL) Mechanism used. [...]
+ "securityProtocol": { "index": 101, "kind": "property", "displayName":
"Security Protocol", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PLAINTEXT", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Protocol used to communicate with brokers.
SASL_PLAINTEXT, [...]
+ "sslCipherSuites": { "index": 102, "kind": "property", "displayName": "Ssl
Cipher Suites", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of cipher suites. This is a named
combination of authentication, encryption, MAC a [...]
+ "sslContextParameters": { "index": 103, "kind": "property", "displayName":
"Ssl Context Parameters", "group": "security", "label": "common,security",
"required": false, "type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "SSL configuration using a Camel SSLContextPar
[...]
+ "sslEnabledProtocols": { "index": 104, "kind": "property", "displayName":
"Ssl Enabled Protocols", "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 list of protocols enabled for SSL
connections. The default is TLSv1.2,TLSv1.3 [...]
+ "sslEndpointAlgorithm": { "index": 105, "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 serv [...]
+ "sslKeymanagerAlgorithm": { "index": 106, "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
SS [...]
+ "sslKeyPassword": { "index": 107, "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 sslKeystor [...]
+ "sslKeystoreLocation": { "index": 108, "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 us [...]
+ "sslKeystorePassword": { "index": 109, "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": 110, "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 the cl [...]
+ "sslProtocol": { "index": 111, "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": 112, "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 [...]
+ "sslTrustmanagerAlgorithm": { "index": 113, "kind": "property",
"displayName": "Ssl Trustmanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "PKIX", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by trust manager factory
for [...]
+ "sslTruststoreLocation": { "index": 114, "kind": "property",
"displayName": "Ssl Truststore 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
trust store file." },
+ "sslTruststorePassword": { "index": 115, "kind": "property",
"displayName": "Ssl Truststore 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 for the
trust store file. If a password is not set, trust store f [...]
+ "sslTruststoreType": { "index": 116, "kind": "property", "displayName":
"Ssl Truststore 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 trust store file. The
default value is [...]
+ "useGlobalSslContextParameters": { "index": 117, "kind": "property",
"displayName": "Use Global Ssl Context Parameters", "group": "security",
"label": "security", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Enable usage of global SSL context
parameters." }
},
"headers": {
"kafka.PARTITION_KEY": { "index": 0, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"Integer", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Explicitly specify the partition",
"constantName": "org.apache.camel.component.kafka.KafkaConstants#PARTITION_KEY"
},
diff --git a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
index 07c7388a613..89bb61e09cb 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
@@ -740,6 +740,13 @@
"description": "Maximum number the kafka consumer will attempt to
subscribe to the kafka broker, before eventually giving up and failing. Error
during subscribing the consumer to the kafka topic could be temporary errors
due to network issues, and could potentially be recoverable. Camel will by
default retry forever, and therefore never give up. If you want to give up
after many attempts, then set this option and Camel will then when giving up
terminate the consumer. You can manual [...]
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
},
+ {
+ "name": "camel.component.kafka.subscribe-consumer-topic-must-exists",
+ "type": "java.lang.Boolean",
+ "description": "Whether when a Camel Kafka consumer is subscribing to a
Kafka broker then check whether a topic already exist on the broker, and fail
if it does not. Otherwise, the Camel Kafka consumer will keep attempt to
consume from the topic, until it's created on the Kafka broker; and until then
the Camel Kafka consumer will fail and log a WARN about
UNKNOWN_TOPIC_OR_PARTITION. The option subscribeConsumerBackoffMaxAttempts can
be configured to give up trying to subscribe afte [...]
+ "sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
+ "defaultValue": false
+ },
{
"name": "camel.component.kafka.synchronous",
"type": "java.lang.Boolean",
diff --git
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index 8c2afa6b29a..7e5f5bc706a 100644
---
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -429,6 +429,17 @@ public class KafkaComponentConfiguration
* and starting the route, to try again.
*/
private Integer subscribeConsumerBackoffMaxAttempts;
+ /**
+ * Whether when a Camel Kafka consumer is subscribing to a Kafka broker
then
+ * check whether a topic already exist on the broker, and fail if it does
+ * not. Otherwise, the Camel Kafka consumer will keep attempt to consume
+ * from the topic, until it's created on the Kafka broker; and until then
+ * the Camel Kafka consumer will fail and log a WARN about
+ * UNKNOWN_TOPIC_OR_PARTITION. The option
+ * subscribeConsumerBackoffMaxAttempts can be configured to give up trying
+ * to subscribe after a given number of attempts.
+ */
+ private Boolean subscribeConsumerTopicMustExists = false;
/**
* If this feature is enabled and a single element of a batch is an
Exchange
* or Message, the producer will generate individual kafka header values
for
@@ -1320,6 +1331,15 @@ public class KafkaComponentConfiguration
this.subscribeConsumerBackoffMaxAttempts =
subscribeConsumerBackoffMaxAttempts;
}
+ public Boolean getSubscribeConsumerTopicMustExists() {
+ return subscribeConsumerTopicMustExists;
+ }
+
+ public void setSubscribeConsumerTopicMustExists(
+ Boolean subscribeConsumerTopicMustExists) {
+ this.subscribeConsumerTopicMustExists =
subscribeConsumerTopicMustExists;
+ }
+
public Boolean getBatchWithIndividualHeaders() {
return batchWithIndividualHeaders;
}
