This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-spring-boot-4.4.x
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
commit bfd98be7096d9c4c0bbd4d2c97741caf541e8631
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Jun 20 15:20:57 2024 +0200
Regen
---
.../camel/springboot/catalog/components/kafka.json | 144 +++++++++++----------
.../camel-kafka-starter/src/main/docs/kafka.json | 7 +
.../springboot/KafkaComponentConfiguration.java | 14 ++
tooling/camel-spring-boot-dependencies/pom.xml | 10 +-
4 files changed, 99 insertions(+), 76 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 1c5212ae169..e17a67d8543 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
@@ -100,43 +100,44 @@
"retries": { "index": 74, "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 [...]
"retryBackoffMs": { "index": 75, "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": 76, "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": 77, "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": 78, "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": 79, "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": 80, "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": 81, "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": 82, "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": 83, "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": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "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": 95, "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": 96, "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": 97, "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, P [...]
- "sslCipherSuites": { "index": 98, "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 an [...]
- "sslContextParameters": { "index": 99, "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 SSLContextPara
[...]
- "sslEnabledProtocols": { "index": 100, "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": 101, "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": 102, "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": 103, "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": 104, "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": 105, "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": 106, "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": 107, "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": 108, "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": 109, "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": 110, "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": 111, "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": 112, "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": 113, "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." }
+ "useIterator": { "index": 77, "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": 78, "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": 79, "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": 80, "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": 81, "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": 82, "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": 83, "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": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "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": 95, "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": 96, "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": 97, "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": 98, "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, P [...]
+ "sslCipherSuites": { "index": 99, "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 an [...]
+ "sslContextParameters": { "index": 100, "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": 101, "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": 102, "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": 103, "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": 104, "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": 105, "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": 106, "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": 107, "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": 108, "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": 109, "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": 110, "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": 111, "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": 112, "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": 113, "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": 114, "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"
},
@@ -227,39 +228,40 @@
"retries": { "index": 70, "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 that has failed to be sent due to a [...]
"retryBackoffMs": { "index": 71, "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": 72, "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": 73, "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": 74, "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 [...]
- "workerPoolCoreSize": { "index": 75, "kind": "parameter", "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 E [...]
- "workerPoolMaxSize": { "index": 76, "kind": "parameter", "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 [...]
- "lazyStartProducer": { "index": 77, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "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 produ [...]
- "kafkaClientFactory": { "index": 78, "kind": "parameter", "displayName":
"Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false,
"autowired": false, "secret": false, "description": "Factory to use for
creating org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances. This allows to
configure a custo [...]
- "synchronous": { "index": 79, "kind": "parameter", "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" },
- "interceptorClasses": { "index": 80, "kind": "parameter", "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 cl [...]
- "schemaRegistryURL": { "index": 81, "kind": "parameter", "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 [...]
- "kerberosBeforeReloginMinTime": { "index": 82, "kind": "parameter",
"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 re [...]
- "kerberosConfigLocation": { "index": 83, "kind": "parameter",
"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": 84, "kind": "parameter", "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\/ [...]
- "kerberosPrincipalToLocalRules": { "index": 85, "kind": "parameter",
"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": 86, "kind": "parameter", "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": 87, "kind": "parameter",
"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 w
[...]
- "saslJaasConfig": { "index": 88, "kind": "parameter", "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. [...]
- "saslKerberosServiceName": { "index": 89, "kind": "parameter",
"displayName": "Sasl Kerberos Service Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be defined eith [...]
- "saslMechanism": { "index": 90, "kind": "parameter", "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": 91, "kind": "parameter", "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": 92, "kind": "parameter", "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": 93, "kind": "parameter", "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": 94, "kind": "parameter", "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": 95, "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": 96, "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": 97, "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": 98, "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": 99, "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": 100, "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 the c [...]
- "sslProtocol": { "index": 101, "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 1 [...]
- "sslProvider": { "index": 102, "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 [...]
- "sslTrustmanagerAlgorithm": { "index": 103, "kind": "parameter",
"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 fo
[...]
- "sslTruststoreLocation": { "index": 104, "kind": "parameter",
"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": 105, "kind": "parameter",
"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 [...]
- "sslTruststoreType": { "index": 106, "kind": "parameter", "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 [...]
+ "useIterator": { "index": 73, "kind": "parameter", "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 jav [...]
+ "valueSerializer": { "index": 74, "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": 75, "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 [...]
+ "workerPoolCoreSize": { "index": 76, "kind": "parameter", "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 E [...]
+ "workerPoolMaxSize": { "index": 77, "kind": "parameter", "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 [...]
+ "lazyStartProducer": { "index": 78, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "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 produ [...]
+ "kafkaClientFactory": { "index": 79, "kind": "parameter", "displayName":
"Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false,
"autowired": false, "secret": false, "description": "Factory to use for
creating org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances. This allows to
configure a custo [...]
+ "synchronous": { "index": 80, "kind": "parameter", "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" },
+ "interceptorClasses": { "index": 81, "kind": "parameter", "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 cl [...]
+ "schemaRegistryURL": { "index": 82, "kind": "parameter", "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 [...]
+ "kerberosBeforeReloginMinTime": { "index": 83, "kind": "parameter",
"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 re [...]
+ "kerberosConfigLocation": { "index": 84, "kind": "parameter",
"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": 85, "kind": "parameter", "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\/ [...]
+ "kerberosPrincipalToLocalRules": { "index": 86, "kind": "parameter",
"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": 87, "kind": "parameter", "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": 88, "kind": "parameter",
"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 w
[...]
+ "saslJaasConfig": { "index": 89, "kind": "parameter", "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. [...]
+ "saslKerberosServiceName": { "index": 90, "kind": "parameter",
"displayName": "Sasl Kerberos Service Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The Kerberos principal
name that Kafka runs as. This can be defined eith [...]
+ "saslMechanism": { "index": 91, "kind": "parameter", "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": 92, "kind": "parameter", "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": 93, "kind": "parameter", "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": 94, "kind": "parameter", "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": 95, "kind": "parameter", "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": 96, "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": 97, "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": 98, "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": 99, "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": 100, "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 on [...]
+ "sslKeystoreType": { "index": 101, "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 the c [...]
+ "sslProtocol": { "index": 102, "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 1 [...]
+ "sslProvider": { "index": 103, "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 [...]
+ "sslTrustmanagerAlgorithm": { "index": 104, "kind": "parameter",
"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 fo
[...]
+ "sslTruststoreLocation": { "index": 105, "kind": "parameter",
"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": 106, "kind": "parameter",
"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 [...]
+ "sslTruststoreType": { "index": 107, "kind": "parameter", "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 [...]
}
}
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 0eb2a3c07db..ebe92dd8d8a 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
@@ -747,6 +747,13 @@
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.kafka.use-iterator",
+ "type": "java.lang.Boolean",
+ "description": "Sets whether sending to kafka should send the message
body as a single record, or use a java.util.Iterator to send multiple records
to kafka (if the message body can be iterated).",
+ "sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
+ "defaultValue": true
+ },
{
"name": "camel.component.kafka.value-deserializer",
"type": "java.lang.String",
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 49c52b40d01..2d5a28d5b8d 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
@@ -654,6 +654,12 @@ public class KafkaComponentConfiguration
* Socket write buffer size
*/
private Integer sendBufferBytes = 131072;
+ /**
+ * Sets whether sending to kafka should send the message body as a single
+ * record, or use a java.util.Iterator to send multiple records to kafka
(if
+ * the message body can be iterated).
+ */
+ private Boolean useIterator = true;
/**
* The serializer class for messages.
*/
@@ -1510,6 +1516,14 @@ public class KafkaComponentConfiguration
this.sendBufferBytes = sendBufferBytes;
}
+ public Boolean getUseIterator() {
+ return useIterator;
+ }
+
+ public void setUseIterator(Boolean useIterator) {
+ this.useIterator = useIterator;
+ }
+
public String getValueSerializer() {
return valueSerializer;
}
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index 9b887a88a97..2a7b4ed1ce8 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -210,27 +210,27 @@
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-commons</artifactId>
- <version>1.12.6</version>
+ <version>1.12.7</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-observation</artifactId>
- <version>1.12.6</version>
+ <version>1.12.7</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-registry-jmx</artifactId>
- <version>1.12.6</version>
+ <version>1.12.7</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-registry-prometheus</artifactId>
- <version>1.12.6</version>
+ <version>1.12.7</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-tracing</artifactId>
- <version>1.2.6</version>
+ <version>1.2.7</version>
</dependency>
<dependency>
<groupId>net.bytebuddy</groupId>
