This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 11cb442afb41e80bd4ba9a2c42499b9e255d2552
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Sep 5 18:53:54 2022 +0200
CAMEL-18243: [DOCS] Kafka component - multiple options need updates
---
.../org/apache/camel/catalog/components/kafka.json | 12 ++++++------
.../org/apache/camel/component/kafka/kafka.json | 12 ++++++------
.../camel/component/kafka/KafkaConfiguration.java | 17 ++++++++++-------
3 files changed, 22 insertions(+), 19 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 f78064e1c72..836af7aa9fb 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
@@ -76,12 +76,12 @@
"keySerializer": { "kind": "property", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for keys (defaults t [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"lingerMs": { "kind": "property", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions into a single ba [...]
- "maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long sending to
kafka will block. These methods can be blocked [...]
+ "maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor(), initTransact [...]
"maxInFlightRequest": { "kind": "property", "displayName": "Max In Flight
Request", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unacknowledged requests
the client will send on a single c [...]
"maxRequestSize": { "kind": "property", "displayName": "Max Request Size",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum size of a request. This is also
effectively a cap on the maximum record [...]
"metadataMaxAgeMs": { "kind": "property", "displayName": "Metadata Max Age
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "300000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The period of time in milliseconds after which
we force a refresh of metadata e [...]
"metricReporters": { "kind": "property", "displayName": "Metric
Reporters", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of classes to use as metrics reporters.
Implementing the MetricReporter interface allows plugging in cla [...]
- "metricsSampleWindowMs": { "kind": "property", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The number of samples
maintained to compute metrics." },
+ "metricsSampleWindowMs": { "kind": "property", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The window of time a
metrics sample is computed over." },
"noOfMetricsSample": { "kind": "property", "displayName": "No Of Metrics
Sample", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "2", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of samples maintained to compute
metrics." },
"partitioner": { "kind": "property", "displayName": "Partitioner",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The partitioner class
for partitioning [...]
"partitionKey": { "kind": "property", "displayName": "Partition Key",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The partition to which the record will be sent
(or null if no partition was specified). If this option has been con [...]
@@ -106,7 +106,7 @@
"interceptorClasses": { "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 classes implemen [...]
"kerberosBeforeReloginMinTime": { "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 refresh
attempts." },
"kerberosInitCmd": { "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\/kinit" },
- "kerberosPrincipalToLocalRules": { "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 principal nam
[...]
+ "kerberosPrincipalToLocalRules": { "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 principal nam
[...]
"kerberosRenewJitter": { "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": { "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
window factor o [...]
"saslJaasConfig": { "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.PlainLoginModu [...]
@@ -196,12 +196,12 @@
"key": { "kind": "parameter", "displayName": "Key", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The record key (or null
if no key is specified). If this option has been configured then it take
precedence over header KafkaConstants#KEY" },
"keySerializer": { "kind": "parameter", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for keys (defaults [...]
"lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions into a single b [...]
- "maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long sending to
kafka will block. These methods can be blocke [...]
+ "maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor(), initTransac [...]
"maxInFlightRequest": { "kind": "parameter", "displayName": "Max In Flight
Request", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unacknowledged requests
the client will send on a single [...]
"maxRequestSize": { "kind": "parameter", "displayName": "Max Request
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum size of a request. This is also
effectively a cap on the maximum recor [...]
"metadataMaxAgeMs": { "kind": "parameter", "displayName": "Metadata Max
Age Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "300000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The period of time in milliseconds after which
we force a refresh of metadata [...]
"metricReporters": { "kind": "parameter", "displayName": "Metric
Reporters", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of classes to use as metrics reporters.
Implementing the MetricReporter interface allows plugging in cl [...]
- "metricsSampleWindowMs": { "kind": "parameter", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The number of samples
maintained to compute metrics." },
+ "metricsSampleWindowMs": { "kind": "parameter", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The window of time a
metrics sample is computed over." },
"noOfMetricsSample": { "kind": "parameter", "displayName": "No Of Metrics
Sample", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "2", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of samples maintained to compute
metrics." },
"partitioner": { "kind": "parameter", "displayName": "Partitioner",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The partitioner class
for partitionin [...]
"partitionKey": { "kind": "parameter", "displayName": "Partition Key",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The partition to which the record will be sent
(or null if no partition was specified). If this option has been co [...]
@@ -226,7 +226,7 @@
"interceptorClasses": { "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 classes impleme [...]
"kerberosBeforeReloginMinTime": { "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 refresh
attempts." },
"kerberosInitCmd": { "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\/kinit" },
- "kerberosPrincipalToLocalRules": { "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 principal na
[...]
+ "kerberosPrincipalToLocalRules": { "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 principal na
[...]
"kerberosRenewJitter": { "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": { "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
window factor [...]
"saslJaasConfig": { "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.PlainLoginMod [...]
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 f78064e1c72..836af7aa9fb 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
@@ -76,12 +76,12 @@
"keySerializer": { "kind": "property", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for keys (defaults t [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"lingerMs": { "kind": "property", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions into a single ba [...]
- "maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long sending to
kafka will block. These methods can be blocked [...]
+ "maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor(), initTransact [...]
"maxInFlightRequest": { "kind": "property", "displayName": "Max In Flight
Request", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unacknowledged requests
the client will send on a single c [...]
"maxRequestSize": { "kind": "property", "displayName": "Max Request Size",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum size of a request. This is also
effectively a cap on the maximum record [...]
"metadataMaxAgeMs": { "kind": "property", "displayName": "Metadata Max Age
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "300000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The period of time in milliseconds after which
we force a refresh of metadata e [...]
"metricReporters": { "kind": "property", "displayName": "Metric
Reporters", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of classes to use as metrics reporters.
Implementing the MetricReporter interface allows plugging in cla [...]
- "metricsSampleWindowMs": { "kind": "property", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The number of samples
maintained to compute metrics." },
+ "metricsSampleWindowMs": { "kind": "property", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The window of time a
metrics sample is computed over." },
"noOfMetricsSample": { "kind": "property", "displayName": "No Of Metrics
Sample", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "2", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of samples maintained to compute
metrics." },
"partitioner": { "kind": "property", "displayName": "Partitioner",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The partitioner class
for partitioning [...]
"partitionKey": { "kind": "property", "displayName": "Partition Key",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The partition to which the record will be sent
(or null if no partition was specified). If this option has been con [...]
@@ -106,7 +106,7 @@
"interceptorClasses": { "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 classes implemen [...]
"kerberosBeforeReloginMinTime": { "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 refresh
attempts." },
"kerberosInitCmd": { "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\/kinit" },
- "kerberosPrincipalToLocalRules": { "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 principal nam
[...]
+ "kerberosPrincipalToLocalRules": { "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 principal nam
[...]
"kerberosRenewJitter": { "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": { "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
window factor o [...]
"saslJaasConfig": { "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.PlainLoginModu [...]
@@ -196,12 +196,12 @@
"key": { "kind": "parameter", "displayName": "Key", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The record key (or null
if no key is specified). If this option has been configured then it take
precedence over header KafkaConstants#KEY" },
"keySerializer": { "kind": "parameter", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for keys (defaults [...]
"lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The producer groups together any records that
arrive in between request transmissions into a single b [...]
- "maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long sending to
kafka will block. These methods can be blocke [...]
+ "maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "60000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The configuration controls how long the
KafkaProducer's send(), partitionsFor(), initTransac [...]
"maxInFlightRequest": { "kind": "parameter", "displayName": "Max In Flight
Request", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unacknowledged requests
the client will send on a single [...]
"maxRequestSize": { "kind": "parameter", "displayName": "Max Request
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum size of a request. This is also
effectively a cap on the maximum recor [...]
"metadataMaxAgeMs": { "kind": "parameter", "displayName": "Metadata Max
Age Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "300000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The period of time in milliseconds after which
we force a refresh of metadata [...]
"metricReporters": { "kind": "parameter", "displayName": "Metric
Reporters", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "A list of classes to use as metrics reporters.
Implementing the MetricReporter interface allows plugging in cl [...]
- "metricsSampleWindowMs": { "kind": "parameter", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The number of samples
maintained to compute metrics." },
+ "metricsSampleWindowMs": { "kind": "parameter", "displayName": "Metrics
Sample Window Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "30000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The window of time a
metrics sample is computed over." },
"noOfMetricsSample": { "kind": "parameter", "displayName": "No Of Metrics
Sample", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "2", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of samples maintained to compute
metrics." },
"partitioner": { "kind": "parameter", "displayName": "Partitioner",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The partitioner class
for partitionin [...]
"partitionKey": { "kind": "parameter", "displayName": "Partition Key",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The partition to which the record will be sent
(or null if no partition was specified). If this option has been co [...]
@@ -226,7 +226,7 @@
"interceptorClasses": { "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 classes impleme [...]
"kerberosBeforeReloginMinTime": { "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 refresh
attempts." },
"kerberosInitCmd": { "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\/kinit" },
- "kerberosPrincipalToLocalRules": { "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 principal na
[...]
+ "kerberosPrincipalToLocalRules": { "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 principal na
[...]
"kerberosRenewJitter": { "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": { "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
window factor [...]
"saslJaasConfig": { "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.PlainLoginMod [...]
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 0670ae1dd3f..e1544b54008 100644
---
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
@@ -1017,7 +1017,7 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
* are evaluated in order and the first rule that matches a principal name
is used to map it to a short name. Any
* later rules in the list are ignored. By default, principal names of the
form {username}/{hostname}@{REALM} are
* mapped to {username}. For more details on the format please see the
security authorization and acls
- * documentation..
+ * documentation (at the Apache Kafka project).
* <p/>
* Multiple values can be separated by comma
*/
@@ -1381,11 +1381,14 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
}
/**
- * The configuration controls how long sending to kafka will block. These
methods can be blocked for multiple
- * reasons. For e.g: buffer full, metadata unavailable.This configuration
imposes maximum limit on the total time
- * spent in fetching metadata, serialization of key and value,
partitioning and allocation of buffer memory when
- * doing a send(). In case of partitionsFor(), this configuration imposes
a maximum time threshold on waiting for
- * metadata
+ * The configuration controls how long the KafkaProducer's send(),
partitionsFor(),
+ * initTransactions(), sendOffsetsToTransaction(), commitTransaction()
+ * and abortTransaction() methods will block.
+ * For send() this timeout bounds the total time waiting for both metadata
fetch and buffer allocation
+ * (blocking in the user-supplied serializers or partitioner is not
counted against this timeout).
+ * For partitionsFor() this timeout bounds the time spent waiting for
metadata if it is unavailable.
+ * The transaction-related methods always block, but may timeout if
+ * the transaction coordinator could not be discovered or did not respond
within the timeout.
*/
public void setMaxBlockMs(Integer maxBlockMs) {
this.maxBlockMs = maxBlockMs;
@@ -1469,7 +1472,7 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
}
/**
- * The number of samples maintained to compute metrics.
+ * The window of time a metrics sample is computed over.
*/
public void setMetricsSampleWindowMs(Integer metricsSampleWindowMs) {
this.metricsSampleWindowMs = metricsSampleWindowMs;
