This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/master by this push:
new acb9f8c [create-pull-request] automated change (#219)
acb9f8c is described below
commit acb9f8caf3beb1b613f03bfd3cd9b4ecef6d8fd7
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Oct 30 06:19:31 2020 +0100
[create-pull-request] automated change (#219)
Co-authored-by: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
---
.../camel/springboot/catalog/components/kafka.json | 16 +++---
.../src/main/docs/kafka-starter.adoc | 8 +--
.../springboot/KafkaComponentConfiguration.java | 60 +++++++++++-----------
docs/modules/ROOT/pages/kafka-starter.adoc | 8 +--
4 files changed, 45 insertions(+), 47 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
index 54cfce5..4316b92 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
@@ -44,8 +44,8 @@
"fetchMinBytes": { "kind": "property", "displayName": "Fetch Min Bytes",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The minimum amount of data the server should
return for a fetch request. If insufficient data is available the [...]
"fetchWaitMaxMs": { "kind": "property", "displayName": "Fetch Wait Max
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "500", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of time the server will
block before answering the fetch request if there isn't suffici [...]
"groupId": { "kind": "property", "displayName": "Group Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "A string that uniquely
identifies the group of consumer processes to which this consumer belongs. By
setting the same group id multiple processes i [...]
+ "headerDeserializer": { "kind": "property", "displayName": "Header
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to
deserialize kafka headers values" },
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "3000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The expected time between heartbeats to the
consumer coordinator when using Kafka's group manage [...]
- "kafkaHeaderDeserializer": { "kind": "property", "displayName": "Kafka
Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to
deserialize kafka headers [...]
"keyDeserializer": { "kind": "property", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
key that implements the Deserial [...]
"maxPartitionFetchBytes": { "kind": "property", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server will return. The maximum total mem [...]
"maxPollIntervalMs": { "kind": "property", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amoun [...]
@@ -63,9 +63,9 @@
"compressionCodec": { "kind": "property", "displayName": "Compression
Codec", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "none", "gzip", "snappy",
"lz4" ], "deprecated": false, "secret": false, "defaultValue": "none",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This parameter allows
you to specify the compression codec f [...]
"connectionMaxIdleMs": { "kind": "property", "displayName": "Connection
Max Idle Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "540000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Close idle connections after the number of
milliseconds specified by this config." },
"enableIdempotence": { "kind": "property", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "If set to 'true' the producer will ensure that
exactly one copy of each message is written in the stream. If 'fa [...]
- "kafkaHeaderSerializer": { "kind": "property", "displayName": "Kafka
Header Serializer", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderSerializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderSerializer to
serialize kafka headers values" },
+ "headerSerializer": { "kind": "property", "displayName": "Header
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderSerializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderSerializer to
serialize kafka headers values" },
"key": { "kind": "property", "displayName": "Key", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": 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" },
- "keySerializerClass": { "kind": "property", "displayName": "Key Serializer
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": 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 to the sam [...]
+ "keySerializer": { "kind": "property", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": 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 to the same as for me [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": 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 starting and cause the r [...]
"lingerMs": { "kind": "property", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": 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 batched request. Norma
[...]
"maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": 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 for multiple reason [...]
@@ -87,7 +87,7 @@
"retries": { "kind": "property", "displayName": "Retries", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record whose send fails with a potentially transient
er [...]
"retryBackoffMs": { "kind": "property", "displayName": "Retry Backoff Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"defaultValue": "100", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Before each retry, the producer refreshes the
metadata of relevant topics to see if a new leader has been e [...]
"sendBufferBytes": { "kind": "property", "displayName": "Send Buffer
Bytes", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "131072", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Socket write buffer size" },
- "serializerClass": { "kind": "property", "displayName": "Serializer
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "org.apache.kafka.common.serialization.StringSerializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The serializer class for
messages." },
+ "valueSerializer": { "kind": "property", "displayName": "Value
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for messages." },
"workerPool": { "kind": "property", "displayName": "Worker Pool", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "java.util.concurrent.ExecutorService", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknowledge the message that was sent
to [...]
"workerPoolCoreSize": { "kind": "property", "displayName": "Worker Pool
Core Size", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "10", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Number of core threads for the worker pool for
continue routing Exchange after kafka server has ack [...]
"workerPoolMaxSize": { "kind": "property", "displayName": "Worker Pool Max
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "20", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Maximum number of threads for the worker pool
for continue routing Exchange after kafka server has ac [...]
@@ -143,8 +143,8 @@
"fetchMinBytes": { "kind": "parameter", "displayName": "Fetch Min Bytes",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The minimum amount of data the server should
return for a fetch request. If insufficient data is available the [...]
"fetchWaitMaxMs": { "kind": "parameter", "displayName": "Fetch Wait Max
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "500", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of time the server will
block before answering the fetch request if there isn't suffic [...]
"groupId": { "kind": "parameter", "displayName": "Group Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "A string that uniquely
identifies the group of consumer processes to which this consumer belongs. By
setting the same group id multiple processes [...]
+ "headerDeserializer": { "kind": "parameter", "displayName": "Header
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to
deserialize kafka headers values" },
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "3000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The expected time between heartbeats to the
consumer coordinator when using Kafka's group manag [...]
- "kafkaHeaderDeserializer": { "kind": "parameter", "displayName": "Kafka
Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderDeserializer to
deserialize kafka header [...]
"keyDeserializer": { "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
key that implements the Deseria [...]
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server will return. The maximum total me [...]
"maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amou [...]
@@ -163,9 +163,9 @@
"compressionCodec": { "kind": "parameter", "displayName": "Compression
Codec", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "none", "gzip", "snappy",
"lz4" ], "deprecated": false, "secret": false, "defaultValue": "none",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This parameter allows
you to specify the compression codec [...]
"connectionMaxIdleMs": { "kind": "parameter", "displayName": "Connection
Max Idle Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "540000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Close idle connections after the number of
milliseconds specified by this config." },
"enableIdempotence": { "kind": "parameter", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "If set to 'true' the producer will ensure that
exactly one copy of each message is written in the stream. If 'f [...]
- "kafkaHeaderSerializer": { "kind": "parameter", "displayName": "Kafka
Header Serializer", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderSerializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderSerializer to
serialize kafka headers values" },
+ "headerSerializer": { "kind": "parameter", "displayName": "Header
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderSerializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom KafkaHeaderSerializer to
serialize kafka headers values" },
"key": { "kind": "parameter", "displayName": "Key", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": 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" },
- "keySerializerClass": { "kind": "parameter", "displayName": "Key
Serializer Class", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": 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 to the
sa [...]
+ "keySerializer": { "kind": "parameter", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": 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 to the same as for m [...]
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": 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 starting and cause the [...]
"lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": 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 batched request. Norm
[...]
"maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": 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 for multiple reaso [...]
@@ -187,7 +187,7 @@
"retries": { "kind": "parameter", "displayName": "Retries", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"defaultValue": "0", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record whose send fails with a potentially transient e
[...]
"retryBackoffMs": { "kind": "parameter", "displayName": "Retry Backoff
Ms", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "100", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Before each retry, the producer refreshes the
metadata of relevant topics to see if a new leader has been [...]
"sendBufferBytes": { "kind": "parameter", "displayName": "Send Buffer
Bytes", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "131072", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Socket write buffer size" },
- "serializerClass": { "kind": "parameter", "displayName": "Serializer
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "org.apache.kafka.common.serialization.StringSerializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The serializer class for
messages." },
+ "valueSerializer": { "kind": "parameter", "displayName": "Value
Serializer", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for messages." },
"workerPool": { "kind": "parameter", "displayName": "Worker Pool",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "java.util.concurrent.ExecutorService", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknowledge the message that was sent t
[...]
"workerPoolCoreSize": { "kind": "parameter", "displayName": "Worker Pool
Core Size", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": "10", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Number of core threads for the worker pool for
continue routing Exchange after kafka server has ac [...]
"workerPoolMaxSize": { "kind": "parameter", "displayName": "Worker Pool
Max Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "defaultValue": "20", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Maximum number of threads for the worker pool
for continue routing Exchange after kafka server has a [...]
diff --git
a/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
b/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
index 2861c28..54f6ef5 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc
@@ -48,11 +48,11 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.fetch-min-bytes* | The minimum amount of data the
server should return for a fetch request. If insufficient data is available the
request will wait for that much data to accumulate before answering the
request. | 1 | Integer
| *camel.component.kafka.fetch-wait-max-ms* | The maximum amount of time the
server will block before answering the fetch request if there isn't sufficient
data to immediately satisfy fetch.min.bytes | 500 | Integer
| *camel.component.kafka.group-id* | A string that uniquely identifies the
group of consumer processes to which this consumer belongs. By setting the same
group id multiple processes indicate that they are all part of the same
consumer group. This option is required for consumers. | | String
+| *camel.component.kafka.header-deserializer* | To use a custom
KafkaHeaderDeserializer to deserialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer type. | |
KafkaHeaderDeserializer
| *camel.component.kafka.header-filter-strategy* | To use a custom
HeaderFilterStrategy to filter header to and from Camel message. The option is
a org.apache.camel.spi.HeaderFilterStrategy type. | | HeaderFilterStrategy
+| *camel.component.kafka.header-serializer* | To use a custom
KafkaHeaderSerializer to serialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type. | |
KafkaHeaderSerializer
| *camel.component.kafka.heartbeat-interval-ms* | The expected time between
heartbeats to the consumer coordinator when using Kafka's group management
facilities. Heartbeats are used to ensure that the consumer's session stays
active and to facilitate rebalancing when new consumers join or leave the
group. The value must be set lower than session.timeout.ms, but typically
should be set no higher than 1/3 of that value. It can be adjusted even lower
to control the expected time for normal [...]
| *camel.component.kafka.interceptor-classes* | Sets interceptors for producer
or consumers. Producer interceptors have to be classes implementing
org.apache.kafka.clients.producer.ProducerInterceptor Consumer interceptors
have to be classes implementing
org.apache.kafka.clients.consumer.ConsumerInterceptor Note that if you use
Producer interceptor on a consumer it will throw a class cast exception in
runtime | | String
-| *camel.component.kafka.kafka-header-deserializer* | To use a custom
KafkaHeaderDeserializer to deserialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer type. | |
KafkaHeaderDeserializer
-| *camel.component.kafka.kafka-header-serializer* | To use a custom
KafkaHeaderSerializer to serialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type. | |
KafkaHeaderSerializer
| *camel.component.kafka.kafka-manual-commit-factory* | Factory to use for
creating KafkaManualCommit instances. This allows to plugin a custom factory to
create custom KafkaManualCommit instances in case special logic is needed when
doing manual commits that deviates from the default implementation that comes
out of the box. The option is a
org.apache.camel.component.kafka.KafkaManualCommitFactory type. | |
KafkaManualCommitFactory
| *camel.component.kafka.kerberos-before-relogin-min-time* | Login thread
sleep time between refresh attempts. | 60000 | Integer
| *camel.component.kafka.kerberos-init-cmd* | Kerberos kinit command path.
Default is /usr/bin/kinit | /usr/bin/kinit | String
@@ -61,7 +61,7 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.kerberos-renew-window-factor* | Login thread will
sleep until the specified window factor of time from last refresh to ticket's
expiry has been reached, at which time it will try to renew the ticket. | |
Double
| *camel.component.kafka.key* | The record key (or null if no key is
specified). If this option has been configured then it take precedence over
header KafkaConstants#KEY | | String
| *camel.component.kafka.key-deserializer* | Deserializer class for key that
implements the Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
-| *camel.component.kafka.key-serializer-class* | The serializer class for keys
(defaults to the same as for messages if nothing is given). |
org.apache.kafka.common.serialization.StringSerializer | String
+| *camel.component.kafka.key-serializer* | The serializer class for keys
(defaults to the same as for messages if nothing is given). |
org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.kafka.lazy-start-producer* | 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 starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
| *camel.component.kafka.linger-ms* | The producer groups together any records
that arrive in between request transmissions into a single batched request.
Normally this occurs only under load when records arrive faster than they can
be sent out. However in some circumstances the client may want to reduce the
number of requests even under moderate load. This setting accomplishes this by
adding a small amount of artificial delay that is, rather than immediately
sending out a record the pro [...]
| *camel.component.kafka.max-block-ms* | 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 | 6 [...]
@@ -96,7 +96,6 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.security-protocol* | Protocol used to communicate
with brokers. SASL_PLAINTEXT, PLAINTEXT and SSL are supported | PLAINTEXT |
String
| *camel.component.kafka.seek-to* | Set if KafkaConsumer will read from
beginning or end on startup: beginning : read from beginning end : read from
end This is replacing the earlier property seekToBeginning | | String
| *camel.component.kafka.send-buffer-bytes* | Socket write buffer size |
131072 | Integer
-| *camel.component.kafka.serializer-class* | The serializer class for
messages. | org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.kafka.session-timeout-ms* | The timeout used to detect
failures when using Kafka's group management facilities. | 10000 | Integer
| *camel.component.kafka.shutdown-timeout* | Timeout in milli seconds to wait
gracefully for the consumer or producer to shutdown and terminate its worker
threads. | 30000 | Integer
| *camel.component.kafka.specific-avro-reader* | This enables the use of a
specific Avro reader for use with the Confluent Platform schema registry and
the io.confluent.kafka.serializers.KafkaAvroDeserializer. This option is only
available in the Confluent Platform (not standard Apache Kafka) | false |
Boolean
@@ -118,6 +117,7 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.topic-is-pattern* | Whether the topic is a pattern
(regular expression). This can be used to subscribe to dynamic number of topics
matching the pattern. | false | Boolean
| *camel.component.kafka.use-global-ssl-context-parameters* | Enable usage of
global SSL context parameters. | false | Boolean
| *camel.component.kafka.value-deserializer* | Deserializer class for value
that implements the Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
+| *camel.component.kafka.value-serializer* | The serializer class for
messages. | org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.kafka.worker-pool* | To use a custom worker pool for
continue routing Exchange after kafka server has acknowledge the message that
was sent to it from KafkaProducer using asynchronous non-blocking processing.
If using this option then you must handle the lifecycle of the thread pool to
shut the pool down when no longer needed. The option is a
java.util.concurrent.ExecutorService type. | | ExecutorService
| *camel.component.kafka.worker-pool-core-size* | Number of core threads for
the worker pool for continue routing Exchange after kafka server has
acknowledge the message that was sent to it from KafkaProducer using
asynchronous non-blocking processing. | 10 | Integer
| *camel.component.kafka.worker-pool-max-size* | Maximum number of threads for
the worker pool for continue routing Exchange after kafka server has
acknowledge the message that was sent to it from KafkaProducer using
asynchronous non-blocking processing. | 20 | Integer
diff --git
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index c0bfd0b..ea408ba 100644
---
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -194,6 +194,12 @@ public class KafkaComponentConfiguration
*/
private String groupId;
/**
+ * To use a custom KafkaHeaderDeserializer to deserialize kafka headers
+ * values. The option is a
+ * org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer type.
+ */
+ private KafkaHeaderDeserializer headerDeserializer;
+ /**
* The expected time between heartbeats to the consumer coordinator when
* using Kafka's group management facilities. Heartbeats are used to ensure
* that the consumer's session stays active and to facilitate rebalancing
@@ -204,12 +210,6 @@ public class KafkaComponentConfiguration
*/
private Integer heartbeatIntervalMs = 3000;
/**
- * To use a custom KafkaHeaderDeserializer to deserialize kafka headers
- * values. The option is a
- * org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer type.
- */
- private KafkaHeaderDeserializer kafkaHeaderDeserializer;
- /**
* Deserializer class for key that implements the Deserializer interface.
*/
private String keyDeserializer =
"org.apache.kafka.common.serialization.StringDeserializer";
@@ -324,7 +324,7 @@ public class KafkaComponentConfiguration
* The option is a
* org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type.
*/
- private KafkaHeaderSerializer kafkaHeaderSerializer;
+ private KafkaHeaderSerializer headerSerializer;
/**
* The record key (or null if no key is specified). If this option has been
* configured then it take precedence over header KafkaConstants#KEY
@@ -334,7 +334,7 @@ public class KafkaComponentConfiguration
* The serializer class for keys (defaults to the same as for messages if
* nothing is given).
*/
- private String keySerializerClass =
"org.apache.kafka.common.serialization.StringSerializer";
+ private String keySerializer =
"org.apache.kafka.common.serialization.StringSerializer";
/**
* Whether the producer should be started lazy (on the first message). By
* starting lazy you can use this to allow CamelContext and routes to
@@ -509,7 +509,7 @@ public class KafkaComponentConfiguration
/**
* The serializer class for messages.
*/
- private String serializerClass =
"org.apache.kafka.common.serialization.StringSerializer";
+ private String valueSerializer =
"org.apache.kafka.common.serialization.StringSerializer";
/**
* To use a custom worker pool for continue routing Exchange after kafka
* server has acknowledge the message that was sent to it from
KafkaProducer
@@ -868,21 +868,20 @@ public class KafkaComponentConfiguration
this.groupId = groupId;
}
- public Integer getHeartbeatIntervalMs() {
- return heartbeatIntervalMs;
+ public KafkaHeaderDeserializer getHeaderDeserializer() {
+ return headerDeserializer;
}
- public void setHeartbeatIntervalMs(Integer heartbeatIntervalMs) {
- this.heartbeatIntervalMs = heartbeatIntervalMs;
+ public void setHeaderDeserializer(KafkaHeaderDeserializer
headerDeserializer) {
+ this.headerDeserializer = headerDeserializer;
}
- public KafkaHeaderDeserializer getKafkaHeaderDeserializer() {
- return kafkaHeaderDeserializer;
+ public Integer getHeartbeatIntervalMs() {
+ return heartbeatIntervalMs;
}
- public void setKafkaHeaderDeserializer(
- KafkaHeaderDeserializer kafkaHeaderDeserializer) {
- this.kafkaHeaderDeserializer = kafkaHeaderDeserializer;
+ public void setHeartbeatIntervalMs(Integer heartbeatIntervalMs) {
+ this.heartbeatIntervalMs = heartbeatIntervalMs;
}
public String getKeyDeserializer() {
@@ -1023,13 +1022,12 @@ public class KafkaComponentConfiguration
this.enableIdempotence = enableIdempotence;
}
- public KafkaHeaderSerializer getKafkaHeaderSerializer() {
- return kafkaHeaderSerializer;
+ public KafkaHeaderSerializer getHeaderSerializer() {
+ return headerSerializer;
}
- public void setKafkaHeaderSerializer(
- KafkaHeaderSerializer kafkaHeaderSerializer) {
- this.kafkaHeaderSerializer = kafkaHeaderSerializer;
+ public void setHeaderSerializer(KafkaHeaderSerializer headerSerializer) {
+ this.headerSerializer = headerSerializer;
}
public String getKey() {
@@ -1040,12 +1038,12 @@ public class KafkaComponentConfiguration
this.key = key;
}
- public String getKeySerializerClass() {
- return keySerializerClass;
+ public String getKeySerializer() {
+ return keySerializer;
}
- public void setKeySerializerClass(String keySerializerClass) {
- this.keySerializerClass = keySerializerClass;
+ public void setKeySerializer(String keySerializer) {
+ this.keySerializer = keySerializer;
}
public Boolean getLazyStartProducer() {
@@ -1216,12 +1214,12 @@ public class KafkaComponentConfiguration
this.sendBufferBytes = sendBufferBytes;
}
- public String getSerializerClass() {
- return serializerClass;
+ public String getValueSerializer() {
+ return valueSerializer;
}
- public void setSerializerClass(String serializerClass) {
- this.serializerClass = serializerClass;
+ public void setValueSerializer(String valueSerializer) {
+ this.valueSerializer = valueSerializer;
}
public ExecutorService getWorkerPool() {
diff --git a/docs/modules/ROOT/pages/kafka-starter.adoc
b/docs/modules/ROOT/pages/kafka-starter.adoc
index 2861c28..54f6ef5 100644
--- a/docs/modules/ROOT/pages/kafka-starter.adoc
+++ b/docs/modules/ROOT/pages/kafka-starter.adoc
@@ -48,11 +48,11 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.fetch-min-bytes* | The minimum amount of data the
server should return for a fetch request. If insufficient data is available the
request will wait for that much data to accumulate before answering the
request. | 1 | Integer
| *camel.component.kafka.fetch-wait-max-ms* | The maximum amount of time the
server will block before answering the fetch request if there isn't sufficient
data to immediately satisfy fetch.min.bytes | 500 | Integer
| *camel.component.kafka.group-id* | A string that uniquely identifies the
group of consumer processes to which this consumer belongs. By setting the same
group id multiple processes indicate that they are all part of the same
consumer group. This option is required for consumers. | | String
+| *camel.component.kafka.header-deserializer* | To use a custom
KafkaHeaderDeserializer to deserialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer type. | |
KafkaHeaderDeserializer
| *camel.component.kafka.header-filter-strategy* | To use a custom
HeaderFilterStrategy to filter header to and from Camel message. The option is
a org.apache.camel.spi.HeaderFilterStrategy type. | | HeaderFilterStrategy
+| *camel.component.kafka.header-serializer* | To use a custom
KafkaHeaderSerializer to serialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type. | |
KafkaHeaderSerializer
| *camel.component.kafka.heartbeat-interval-ms* | The expected time between
heartbeats to the consumer coordinator when using Kafka's group management
facilities. Heartbeats are used to ensure that the consumer's session stays
active and to facilitate rebalancing when new consumers join or leave the
group. The value must be set lower than session.timeout.ms, but typically
should be set no higher than 1/3 of that value. It can be adjusted even lower
to control the expected time for normal [...]
| *camel.component.kafka.interceptor-classes* | Sets interceptors for producer
or consumers. Producer interceptors have to be classes implementing
org.apache.kafka.clients.producer.ProducerInterceptor Consumer interceptors
have to be classes implementing
org.apache.kafka.clients.consumer.ConsumerInterceptor Note that if you use
Producer interceptor on a consumer it will throw a class cast exception in
runtime | | String
-| *camel.component.kafka.kafka-header-deserializer* | To use a custom
KafkaHeaderDeserializer to deserialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer type. | |
KafkaHeaderDeserializer
-| *camel.component.kafka.kafka-header-serializer* | To use a custom
KafkaHeaderSerializer to serialize kafka headers values. The option is a
org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type. | |
KafkaHeaderSerializer
| *camel.component.kafka.kafka-manual-commit-factory* | Factory to use for
creating KafkaManualCommit instances. This allows to plugin a custom factory to
create custom KafkaManualCommit instances in case special logic is needed when
doing manual commits that deviates from the default implementation that comes
out of the box. The option is a
org.apache.camel.component.kafka.KafkaManualCommitFactory type. | |
KafkaManualCommitFactory
| *camel.component.kafka.kerberos-before-relogin-min-time* | Login thread
sleep time between refresh attempts. | 60000 | Integer
| *camel.component.kafka.kerberos-init-cmd* | Kerberos kinit command path.
Default is /usr/bin/kinit | /usr/bin/kinit | String
@@ -61,7 +61,7 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.kerberos-renew-window-factor* | Login thread will
sleep until the specified window factor of time from last refresh to ticket's
expiry has been reached, at which time it will try to renew the ticket. | |
Double
| *camel.component.kafka.key* | The record key (or null if no key is
specified). If this option has been configured then it take precedence over
header KafkaConstants#KEY | | String
| *camel.component.kafka.key-deserializer* | Deserializer class for key that
implements the Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
-| *camel.component.kafka.key-serializer-class* | The serializer class for keys
(defaults to the same as for messages if nothing is given). |
org.apache.kafka.common.serialization.StringSerializer | String
+| *camel.component.kafka.key-serializer* | The serializer class for keys
(defaults to the same as for messages if nothing is given). |
org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.kafka.lazy-start-producer* | 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 starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
| *camel.component.kafka.linger-ms* | The producer groups together any records
that arrive in between request transmissions into a single batched request.
Normally this occurs only under load when records arrive faster than they can
be sent out. However in some circumstances the client may want to reduce the
number of requests even under moderate load. This setting accomplishes this by
adding a small amount of artificial delay that is, rather than immediately
sending out a record the pro [...]
| *camel.component.kafka.max-block-ms* | 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 | 6 [...]
@@ -96,7 +96,6 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.security-protocol* | Protocol used to communicate
with brokers. SASL_PLAINTEXT, PLAINTEXT and SSL are supported | PLAINTEXT |
String
| *camel.component.kafka.seek-to* | Set if KafkaConsumer will read from
beginning or end on startup: beginning : read from beginning end : read from
end This is replacing the earlier property seekToBeginning | | String
| *camel.component.kafka.send-buffer-bytes* | Socket write buffer size |
131072 | Integer
-| *camel.component.kafka.serializer-class* | The serializer class for
messages. | org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.kafka.session-timeout-ms* | The timeout used to detect
failures when using Kafka's group management facilities. | 10000 | Integer
| *camel.component.kafka.shutdown-timeout* | Timeout in milli seconds to wait
gracefully for the consumer or producer to shutdown and terminate its worker
threads. | 30000 | Integer
| *camel.component.kafka.specific-avro-reader* | This enables the use of a
specific Avro reader for use with the Confluent Platform schema registry and
the io.confluent.kafka.serializers.KafkaAvroDeserializer. This option is only
available in the Confluent Platform (not standard Apache Kafka) | false |
Boolean
@@ -118,6 +117,7 @@ The component supports 98 options, which are listed below.
| *camel.component.kafka.topic-is-pattern* | Whether the topic is a pattern
(regular expression). This can be used to subscribe to dynamic number of topics
matching the pattern. | false | Boolean
| *camel.component.kafka.use-global-ssl-context-parameters* | Enable usage of
global SSL context parameters. | false | Boolean
| *camel.component.kafka.value-deserializer* | Deserializer class for value
that implements the Deserializer interface. |
org.apache.kafka.common.serialization.StringDeserializer | String
+| *camel.component.kafka.value-serializer* | The serializer class for
messages. | org.apache.kafka.common.serialization.StringSerializer | String
| *camel.component.kafka.worker-pool* | To use a custom worker pool for
continue routing Exchange after kafka server has acknowledge the message that
was sent to it from KafkaProducer using asynchronous non-blocking processing.
If using this option then you must handle the lifecycle of the thread pool to
shut the pool down when no longer needed. The option is a
java.util.concurrent.ExecutorService type. | | ExecutorService
| *camel.component.kafka.worker-pool-core-size* | Number of core threads for
the worker pool for continue routing Exchange after kafka server has
acknowledge the message that was sent to it from KafkaProducer using
asynchronous non-blocking processing. | 10 | Integer
| *camel.component.kafka.worker-pool-max-size* | Maximum number of threads for
the worker pool for continue routing Exchange after kafka server has
acknowledge the message that was sent to it from KafkaProducer using
asynchronous non-blocking processing. | 20 | Integer
