This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 96d3c42c266e0fdd4dcd90e9ce2ceaa3c8c76b2a
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu Oct 29 19:56:20 2020 +0100

    CAMEL-15770 - Regen catalog
---
 .../org/apache/camel/catalog/components/kafka.json       | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 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 91ab79c..2cbc60d 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
@@ -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 [...]

Reply via email to