This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 04e13e3a540 [CAMEL-19412] - camel-kafka - Add kerberos config file
location property.
04e13e3a540 is described below
commit 04e13e3a54090e3be5e5f394e4e1b115cb3cfcc7
Author: Vaishnavi R <[email protected]>
AuthorDate: Fri Jun 30 20:50:27 2023 +0530
[CAMEL-19412] - camel-kafka - Add kerberos config file location property.
Updated the code.
Updated the doc.
Updated the kafkaComponentBuilder.
Updated the code .
Added all the generated files.
Added all the generated files.
Updated the files.
Updated the code.
Updated the code.
Updated the code.
---
.../org/apache/camel/catalog/components/kafka.json | 96 +++++++++++-----------
.../component/kafka/KafkaComponentConfigurer.java | 6 ++
.../component/kafka/KafkaEndpointConfigurer.java | 6 ++
.../component/kafka/KafkaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/kafka/kafka.json | 96 +++++++++++-----------
.../camel-kafka/src/main/docs/kafka-component.adoc | 27 +-----
.../camel/component/kafka/KafkaConfiguration.java | 14 ++++
.../camel/component/kafka/KafkaFetchRecords.java | 5 ++
.../dsl/KafkaComponentBuilderFactory.java | 16 ++++
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 45 ++++++++++
10 files changed, 196 insertions(+), 118 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
index 56b0c15611e..fcc1e560191 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
@@ -106,30 +106,31 @@
"schemaRegistryURL": { "index": 81, "kind": "property", "displayName":
"Schema Registry URL", "group": "confluent", "label": "confluent", "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 Confluent Platform schema registry
servers to use. The format is host1:port1,hos [...]
"interceptorClasses": { "index": 82, "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 [...]
"kerberosBeforeReloginMinTime": { "index": 83, "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 [...]
- "kerberosInitCmd": { "index": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "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": 95, "kind": "property", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serve [...]
- "sslKeymanagerAlgorithm": { "index": 96, "kind": "property",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SSL [...]
- "sslKeyPassword": { "index": 97, "kind": "property", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystore [...]
- "sslKeystoreLocation": { "index": 98, "kind": "property", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used fo [...]
- "sslKeystorePassword": { "index": 99, "kind": "property", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only nee [...]
- "sslKeystoreType": { "index": 100, "kind": "property", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
- "sslProtocol": { "index": 101, "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": 102, "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": 103, "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": 104, "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": 105, "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": 106, "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.
Default value is JKS." },
- "useGlobalSslContextParameters": { "index": 107, "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." }
+ "kerberosConfigLocation": { "index": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "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": 95, "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": 96, "kind": "property", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serve [...]
+ "sslKeymanagerAlgorithm": { "index": 97, "kind": "property",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SSL [...]
+ "sslKeyPassword": { "index": 98, "kind": "property", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystore [...]
+ "sslKeystoreLocation": { "index": 99, "kind": "property", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used fo [...]
+ "sslKeystorePassword": { "index": 100, "kind": "property", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
+ "sslKeystoreType": { "index": 101, "kind": "property", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
+ "sslProtocol": { "index": 102, "kind": "property", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
+ "sslProvider": { "index": 103, "kind": "property", "displayName": "Ssl
Provider", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the security provider used for SSL
connections. Default value is the default security [...]
+ "sslTrustmanagerAlgorithm": { "index": 104, "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": 105, "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": 106, "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": 107, "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.
Default value is JKS." },
+ "useGlobalSslContextParameters": { "index": 108, "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,28 +228,29 @@
"schemaRegistryURL": { "index": 77, "kind": "parameter", "displayName":
"Schema Registry URL", "group": "confluent", "label": "confluent", "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 Confluent Platform schema registry
servers to use. The format is host1:port1,ho [...]
"interceptorClasses": { "index": 78, "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 [...]
"kerberosBeforeReloginMinTime": { "index": 79, "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 [...]
- "kerberosInitCmd": { "index": 80, "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": 81, "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": 82, "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": 83, "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": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "kind": "parameter", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used f [...]
- "sslKeystorePassword": { "index": 95, "kind": "parameter", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
- "sslKeystoreType": { "index": 96, "kind": "parameter", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
- "sslProtocol": { "index": 97, "kind": "parameter", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
- "sslProvider": { "index": 98, "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": 99, "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
for [...]
- "sslTruststoreLocation": { "index": 100, "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": 101, "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": 102, "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.
Default value is JKS." }
+ "kerberosConfigLocation": { "index": 80, "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": 81, "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": 82, "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": 83, "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": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "kind": "parameter", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serv [...]
+ "sslKeymanagerAlgorithm": { "index": 93, "kind": "parameter",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SS [...]
+ "sslKeyPassword": { "index": 94, "kind": "parameter", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystor [...]
+ "sslKeystoreLocation": { "index": 95, "kind": "parameter", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used f [...]
+ "sslKeystorePassword": { "index": 96, "kind": "parameter", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
+ "sslKeystoreType": { "index": 97, "kind": "parameter", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
+ "sslProtocol": { "index": 98, "kind": "parameter", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
+ "sslProvider": { "index": 99, "kind": "parameter", "displayName": "Ssl
Provider", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the security provider used for SSL
connections. Default value is the default security [...]
+ "sslTrustmanagerAlgorithm": { "index": 100, "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": 101, "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": 102, "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": 103, "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.
Default value is JKS." }
}
}
diff --git
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
index 8fc0bf484fc..91642bc2fcd 100644
---
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
+++
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
@@ -100,6 +100,8 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "kafkaManualCommitFactory":
target.setKafkaManualCommitFactory(property(camelContext,
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class,
value)); return true;
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime":
getOrCreateConfiguration(target).setKerberosBeforeReloginMinTime(property(camelContext,
java.lang.Integer.class, value)); return true;
+ case "kerberosconfiglocation":
+ case "kerberosConfigLocation":
getOrCreateConfiguration(target).setKerberosConfigLocation(property(camelContext,
java.lang.String.class, value)); return true;
case "kerberosinitcmd":
case "kerberosInitCmd":
getOrCreateConfiguration(target).setKerberosInitCmd(property(camelContext,
java.lang.String.class, value)); return true;
case "kerberosprincipaltolocalrules":
@@ -322,6 +324,8 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "kafkaManualCommitFactory": return
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class;
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime": return java.lang.Integer.class;
+ case "kerberosconfiglocation":
+ case "kerberosConfigLocation": return java.lang.String.class;
case "kerberosinitcmd":
case "kerberosInitCmd": return java.lang.String.class;
case "kerberosprincipaltolocalrules":
@@ -540,6 +544,8 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "kafkaManualCommitFactory": return
target.getKafkaManualCommitFactory();
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime": return
getOrCreateConfiguration(target).getKerberosBeforeReloginMinTime();
+ case "kerberosconfiglocation":
+ case "kerberosConfigLocation": return
getOrCreateConfiguration(target).getKerberosConfigLocation();
case "kerberosinitcmd":
case "kerberosInitCmd": return
getOrCreateConfiguration(target).getKerberosInitCmd();
case "kerberosprincipaltolocalrules":
diff --git
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
index aa76beb09f8..1f92072e1a3 100644
---
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
+++
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
@@ -90,6 +90,8 @@ public class KafkaEndpointConfigurer extends
PropertyConfigurerSupport implement
case "kafkaManualCommitFactory":
target.setKafkaManualCommitFactory(property(camelContext,
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class,
value)); return true;
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime":
target.getConfiguration().setKerberosBeforeReloginMinTime(property(camelContext,
java.lang.Integer.class, value)); return true;
+ case "kerberosconfiglocation":
+ case "kerberosConfigLocation":
target.getConfiguration().setKerberosConfigLocation(property(camelContext,
java.lang.String.class, value)); return true;
case "kerberosinitcmd":
case "kerberosInitCmd":
target.getConfiguration().setKerberosInitCmd(property(camelContext,
java.lang.String.class, value)); return true;
case "kerberosprincipaltolocalrules":
@@ -296,6 +298,8 @@ public class KafkaEndpointConfigurer extends
PropertyConfigurerSupport implement
case "kafkaManualCommitFactory": return
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class;
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime": return java.lang.Integer.class;
+ case "kerberosconfiglocation":
+ case "kerberosConfigLocation": return java.lang.String.class;
case "kerberosinitcmd":
case "kerberosInitCmd": return java.lang.String.class;
case "kerberosprincipaltolocalrules":
@@ -503,6 +507,8 @@ public class KafkaEndpointConfigurer extends
PropertyConfigurerSupport implement
case "kafkaManualCommitFactory": return
target.getKafkaManualCommitFactory();
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime": return
target.getConfiguration().getKerberosBeforeReloginMinTime();
+ case "kerberosconfiglocation":
+ case "kerberosConfigLocation": return
target.getConfiguration().getKerberosConfigLocation();
case "kerberosinitcmd":
case "kerberosInitCmd": return
target.getConfiguration().getKerberosInitCmd();
case "kerberosprincipaltolocalrules":
diff --git
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointUriFactory.java
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointUriFactory.java
index 6a70d0dc1da..27ab37c0df5 100644
---
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointUriFactory.java
+++
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointUriFactory.java
@@ -21,7 +21,7 @@ public class KafkaEndpointUriFactory extends
org.apache.camel.support.component.
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(103);
+ Set<String> props = new HashSet<>(104);
props.add("additionalProperties");
props.add("allowManualCommit");
props.add("autoCommitEnable");
@@ -57,6 +57,7 @@ public class KafkaEndpointUriFactory extends
org.apache.camel.support.component.
props.add("kafkaClientFactory");
props.add("kafkaManualCommitFactory");
props.add("kerberosBeforeReloginMinTime");
+ props.add("kerberosConfigLocation");
props.add("kerberosInitCmd");
props.add("kerberosPrincipalToLocalRules");
props.add("kerberosRenewJitter");
diff --git
a/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
b/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
index 56b0c15611e..fcc1e560191 100644
---
a/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
+++
b/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
@@ -106,30 +106,31 @@
"schemaRegistryURL": { "index": 81, "kind": "property", "displayName":
"Schema Registry URL", "group": "confluent", "label": "confluent", "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 Confluent Platform schema registry
servers to use. The format is host1:port1,hos [...]
"interceptorClasses": { "index": 82, "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 [...]
"kerberosBeforeReloginMinTime": { "index": 83, "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 [...]
- "kerberosInitCmd": { "index": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "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": 95, "kind": "property", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serve [...]
- "sslKeymanagerAlgorithm": { "index": 96, "kind": "property",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SSL [...]
- "sslKeyPassword": { "index": 97, "kind": "property", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystore [...]
- "sslKeystoreLocation": { "index": 98, "kind": "property", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used fo [...]
- "sslKeystorePassword": { "index": 99, "kind": "property", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only nee [...]
- "sslKeystoreType": { "index": 100, "kind": "property", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
- "sslProtocol": { "index": 101, "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": 102, "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": 103, "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": 104, "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": 105, "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": 106, "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.
Default value is JKS." },
- "useGlobalSslContextParameters": { "index": 107, "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." }
+ "kerberosConfigLocation": { "index": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "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": 95, "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": 96, "kind": "property", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serve [...]
+ "sslKeymanagerAlgorithm": { "index": 97, "kind": "property",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SSL [...]
+ "sslKeyPassword": { "index": 98, "kind": "property", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystore [...]
+ "sslKeystoreLocation": { "index": 99, "kind": "property", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used fo [...]
+ "sslKeystorePassword": { "index": 100, "kind": "property", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
+ "sslKeystoreType": { "index": 101, "kind": "property", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
+ "sslProtocol": { "index": 102, "kind": "property", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
+ "sslProvider": { "index": 103, "kind": "property", "displayName": "Ssl
Provider", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the security provider used for SSL
connections. Default value is the default security [...]
+ "sslTrustmanagerAlgorithm": { "index": 104, "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": 105, "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": 106, "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": 107, "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.
Default value is JKS." },
+ "useGlobalSslContextParameters": { "index": 108, "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,28 +228,29 @@
"schemaRegistryURL": { "index": 77, "kind": "parameter", "displayName":
"Schema Registry URL", "group": "confluent", "label": "confluent", "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 Confluent Platform schema registry
servers to use. The format is host1:port1,ho [...]
"interceptorClasses": { "index": 78, "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 [...]
"kerberosBeforeReloginMinTime": { "index": 79, "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 [...]
- "kerberosInitCmd": { "index": 80, "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": 81, "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": 82, "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": 83, "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": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "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": 93, "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": 94, "kind": "parameter", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used f [...]
- "sslKeystorePassword": { "index": 95, "kind": "parameter", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
- "sslKeystoreType": { "index": 96, "kind": "parameter", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
- "sslProtocol": { "index": 97, "kind": "parameter", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
- "sslProvider": { "index": 98, "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": 99, "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
for [...]
- "sslTruststoreLocation": { "index": 100, "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": 101, "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": 102, "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.
Default value is JKS." }
+ "kerberosConfigLocation": { "index": 80, "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": 81, "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": 82, "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": 83, "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": 84, "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": 85, "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": 86, "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": 87, "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": 88, "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": 89, "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": 90, "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": 91, "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": 92, "kind": "parameter", "displayName":
"Ssl Endpoint Algorithm", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"https", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The endpoint identification algorithm to
validate serv [...]
+ "sslKeymanagerAlgorithm": { "index": 93, "kind": "parameter",
"displayName": "Ssl Keymanager Algorithm", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "SunX509", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The algorithm used by key manager factory for
SS [...]
+ "sslKeyPassword": { "index": 94, "kind": "parameter", "displayName": "Ssl
Key Password", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The password of the private key in the key
store file or the PEM key specified in sslKeystor [...]
+ "sslKeystoreLocation": { "index": 95, "kind": "parameter", "displayName":
"Ssl Keystore Location", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The location of the key store file. This is
optional for client and can be used f [...]
+ "sslKeystorePassword": { "index": 96, "kind": "parameter", "displayName":
"Ssl Keystore Password", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The store password for the key store file.
This is optional for client and only ne [...]
+ "sslKeystoreType": { "index": 97, "kind": "parameter", "displayName": "Ssl
Keystore Type", "group": "security", "label": "common,security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "JKS",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The file format of the
key store file. This is optional for client [...]
+ "sslProtocol": { "index": 98, "kind": "parameter", "displayName": "Ssl
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The SSL protocol used to generate the
SSLContext. The default is TLSv1.3 when running with Java 11 [...]
+ "sslProvider": { "index": 99, "kind": "parameter", "displayName": "Ssl
Provider", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The name of the security provider used for SSL
connections. Default value is the default security [...]
+ "sslTrustmanagerAlgorithm": { "index": 100, "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": 101, "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": 102, "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": 103, "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.
Default value is JKS." }
}
}
diff --git a/components/camel-kafka/src/main/docs/kafka-component.adoc
b/components/camel-kafka/src/main/docs/kafka-component.adoc
index 7b60c6d772b..8405f58461a 100644
--- a/components/camel-kafka/src/main/docs/kafka-component.adoc
+++ b/components/camel-kafka/src/main/docs/kafka-component.adoc
@@ -442,30 +442,11 @@ It would work with JTA `camel-jta` by using
`transacted()` and if it involves so
== Setting Kerberos config file
-Since kafka clients do not expose a way to configure the `krb5.conf` file
directly through their API, you can, if necessary, do this using the JVM system
properties.
-
-Through command line:
-[source,bash]
-----
-java -jar myroute.jar -Djava.security.krb5.conf=/path/to/krb5.conf
-----
-
-Through java code:
+Configure the 'krb5.conf' file directly through the API
[source,java]
----
-public class MyRoute extends RouteBuilder {
- static {
- System.setProperty("java.security.krb5.conf", "/path/to/krb5.conf");
- }
-
- // your route
-
+static {
+ KafkaComponent.setKerberosConfigLocation("path/to/config/file");
}
----
-
-[WARNING]
-====
-Keep in mind that once using system properties that config will be applied to
whole JVM so all routes will be affected by this.
-====
-
-include::spring-boot:partial$starter.adoc[]
+include::spring-boot:partial$starter.adoc[]
\ No newline at end of file
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 82cc44d86c1..20686f13463 100755
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -340,6 +340,9 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
description = "Sets whether synchronous processing should be
strictly used")
private boolean synchronous;
+ @UriParam(label = "common,security")
+ private String kerberosConfigLocation;
+
public KafkaConfiguration() {
}
@@ -1875,4 +1878,15 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
public void setIsolationLevel(String isolationLevel) {
this.isolationLevel = isolationLevel;
}
+
+ public String getKerberosConfigLocation() {
+ return kerberosConfigLocation;
+ }
+
+ /**
+ * Location of the kerberos config file.
+ */
+ public void setKerberosConfigLocation(String kerberosConfigLocation) {
+ this.kerberosConfigLocation = kerberosConfigLocation;
+ }
}
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
index 610fab4f9ec..de4b508c4f1 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
@@ -244,6 +244,11 @@ public class KafkaFetchRecords implements Runnable {
// this may throw an exception if something is wrong with kafka
consumer
this.consumer =
kafkaConsumer.getEndpoint().getKafkaClientFactory().getConsumer(kafkaProps);
+ var krbLocation =
kafkaConsumer.getEndpoint().getConfiguration().getKerberosConfigLocation();
+ if (krbLocation != null) {
+ System.setProperty("java.security.krb5.conf", krbLocation);
+ }
+
// init client id which we may need to get from the kafka producer
via reflection
if (clientId == null) {
clientId =
getKafkaProps().getProperty(CommonClientConfigs.CLIENT_ID_CONFIG);
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
index bed5b8695d2..0982fe42567 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
@@ -1688,6 +1688,21 @@ public interface KafkaComponentBuilderFactory {
doSetProperty("kerberosBeforeReloginMinTime",
kerberosBeforeReloginMinTime);
return this;
}
+ /**
+ * Location of the kerberos config file.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param kerberosConfigLocation the value to set
+ * @return the dsl builder
+ */
+ default KafkaComponentBuilder kerberosConfigLocation(
+ java.lang.String kerberosConfigLocation) {
+ doSetProperty("kerberosConfigLocation", kerberosConfigLocation);
+ return this;
+ }
/**
* Kerberos kinit command path. Default is /usr/bin/kinit.
*
@@ -2221,6 +2236,7 @@ public interface KafkaComponentBuilderFactory {
case "schemaRegistryURL":
getOrCreateConfiguration((KafkaComponent)
component).setSchemaRegistryURL((java.lang.String) value); return true;
case "interceptorClasses":
getOrCreateConfiguration((KafkaComponent)
component).setInterceptorClasses((java.lang.String) value); return true;
case "kerberosBeforeReloginMinTime":
getOrCreateConfiguration((KafkaComponent)
component).setKerberosBeforeReloginMinTime((java.lang.Integer) value); return
true;
+ case "kerberosConfigLocation":
getOrCreateConfiguration((KafkaComponent)
component).setKerberosConfigLocation((java.lang.String) value); return true;
case "kerberosInitCmd": getOrCreateConfiguration((KafkaComponent)
component).setKerberosInitCmd((java.lang.String) value); return true;
case "kerberosPrincipalToLocalRules":
getOrCreateConfiguration((KafkaComponent)
component).setKerberosPrincipalToLocalRules((java.lang.String) value); return
true;
case "kerberosRenewJitter":
getOrCreateConfiguration((KafkaComponent)
component).setKerberosRenewJitter((java.lang.Double) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
index 7ac6074c8e6..02ec4c69b27 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
@@ -1308,6 +1308,21 @@ public interface KafkaEndpointBuilderFactory {
doSetProperty("kerberosBeforeReloginMinTime",
kerberosBeforeReloginMinTime);
return this;
}
+ /**
+ * Location of the kerberos config file.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param kerberosConfigLocation the value to set
+ * @return the dsl builder
+ */
+ default KafkaEndpointConsumerBuilder kerberosConfigLocation(
+ String kerberosConfigLocation) {
+ doSetProperty("kerberosConfigLocation", kerberosConfigLocation);
+ return this;
+ }
/**
* Kerberos kinit command path. Default is /usr/bin/kinit.
*
@@ -3524,6 +3539,21 @@ public interface KafkaEndpointBuilderFactory {
doSetProperty("kerberosBeforeReloginMinTime",
kerberosBeforeReloginMinTime);
return this;
}
+ /**
+ * Location of the kerberos config file.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param kerberosConfigLocation the value to set
+ * @return the dsl builder
+ */
+ default KafkaEndpointProducerBuilder kerberosConfigLocation(
+ String kerberosConfigLocation) {
+ doSetProperty("kerberosConfigLocation", kerberosConfigLocation);
+ return this;
+ }
/**
* Kerberos kinit command path. Default is /usr/bin/kinit.
*
@@ -4396,6 +4426,21 @@ public interface KafkaEndpointBuilderFactory {
doSetProperty("kerberosBeforeReloginMinTime",
kerberosBeforeReloginMinTime);
return this;
}
+ /**
+ * Location of the kerberos config file.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param kerberosConfigLocation the value to set
+ * @return the dsl builder
+ */
+ default KafkaEndpointBuilder kerberosConfigLocation(
+ String kerberosConfigLocation) {
+ doSetProperty("kerberosConfigLocation", kerberosConfigLocation);
+ return this;
+ }
/**
* Kerberos kinit command path. Default is /usr/bin/kinit.
*
