This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-spring-boot-4.10.x
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/camel-spring-boot-4.10.x by
this push:
new 111219fa56c CAMEL-21788: camel-kafka - Turn recordMetadata off by
default
111219fa56c is described below
commit 111219fa56cec4101369e0107a0f74fa168b6dcb
Author: Claus Ibsen <[email protected]>
AuthorDate: Tue Feb 25 09:19:35 2025 +0100
CAMEL-21788: camel-kafka - Turn recordMetadata off by default
---
.../camel/springboot/catalog/components/kafka.json | 42 +++++++++++-----------
.../camel-kafka-starter/src/main/docs/kafka.json | 2 +-
.../springboot/KafkaComponentConfiguration.java | 30 ++++++++--------
3 files changed, 37 insertions(+), 37 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 dbe04f117bb..16a0fed6adb 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
@@ -98,16 +98,16 @@
"queueBufferingMaxMessages": { "index": 71, "kind": "property",
"displayName": "Queue Buffering Max Messages", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unsent messages that can
be [...]
"receiveBufferBytes": { "index": 72, "kind": "property", "displayName":
"Receive Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "65536",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP
receive buffer (SO_RCVBUF) to use when readi [...]
"reconnectBackoffMs": { "index": 73, "kind": "property", "displayName":
"Reconnect Backoff Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "50",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to reconnect to a give [...]
- "recordMetadata": { "index": 74, "kind": "property", "displayName":
"Record Metadata", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the producer should store the
RecordMetadata results from sending to Kafka. Th [...]
- "requestRequiredAcks": { "index": 75, "kind": "property", "displayName":
"Request Required Acks", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1",
"0", "1" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "all", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of acknowledgments t [...]
- "requestTimeoutMs": { "index": 76, "kind": "property", "displayName":
"Request Timeout 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 amount of time the
broker will wait trying to meet the request.r [...]
- "retries": { "index": 77, "kind": "property", "displayName": "Retries",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record that has failed to be sent due to a [...]
- "sendBufferBytes": { "index": 78, "kind": "property", "displayName": "Send
Buffer Bytes", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "131072",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Socket write buffer
size" },
- "useIterator": { "index": 79, "kind": "property", "displayName": "Use
Iterator", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether sending to kafka should send the
message body as a single record, or use a java [...]
- "valueSerializer": { "index": 80, "kind": "property", "displayName":
"Value Serializer", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for [...]
- "workerPool": { "index": 81, "kind": "property", "displayName": "Worker
Pool", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "java.util.concurrent.ExecutorService", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknowl [...]
- "workerPoolCoreSize": { "index": 82, "kind": "property", "displayName":
"Worker Pool Core Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Number of core threads
for the worker pool for continue routing Ex [...]
- "workerPoolMaxSize": { "index": 83, "kind": "property", "displayName":
"Worker Pool Max Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "20",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads for the worker pool for continue routing E [...]
+ "requestRequiredAcks": { "index": 74, "kind": "property", "displayName":
"Request Required Acks", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1",
"0", "1" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "all", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of acknowledgments t [...]
+ "requestTimeoutMs": { "index": 75, "kind": "property", "displayName":
"Request Timeout 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 amount of time the
broker will wait trying to meet the request.r [...]
+ "retries": { "index": 76, "kind": "property", "displayName": "Retries",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record that has failed to be sent due to a [...]
+ "sendBufferBytes": { "index": 77, "kind": "property", "displayName": "Send
Buffer Bytes", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "131072",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Socket write buffer
size" },
+ "useIterator": { "index": 78, "kind": "property", "displayName": "Use
Iterator", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether sending to kafka should send the
message body as a single record, or use a java [...]
+ "valueSerializer": { "index": 79, "kind": "property", "displayName":
"Value Serializer", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class for [...]
+ "workerPool": { "index": 80, "kind": "property", "displayName": "Worker
Pool", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "java.util.concurrent.ExecutorService", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknowl [...]
+ "workerPoolCoreSize": { "index": 81, "kind": "property", "displayName":
"Worker Pool Core Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Number of core threads
for the worker pool for continue routing Ex [...]
+ "workerPoolMaxSize": { "index": 82, "kind": "property", "displayName":
"Worker Pool Max Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "20",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads for the worker pool for continue routing E [...]
+ "recordMetadata": { "index": 83, "kind": "property", "displayName":
"Record Metadata", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the producer should store the
RecordMetadata results from [...]
"autowiredEnabled": { "index": 84, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
"kafkaClientFactory": { "index": 85, "kind": "property", "displayName":
"Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false,
"autowired": true, "secret": false, "description": "Factory to use for creating
org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances. This allows
configuring a custom f [...]
"synchronous": { "index": 86, "kind": "property", "displayName":
"Synchronous", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether synchronous processing should be
strictly used" },
@@ -228,17 +228,17 @@
"queueBufferingMaxMessages": { "index": 67, "kind": "parameter",
"displayName": "Queue Buffering Max Messages", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum number of unsent messages that can
b [...]
"receiveBufferBytes": { "index": 68, "kind": "parameter", "displayName":
"Receive Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "65536",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The size of the TCP
receive buffer (SO_RCVBUF) to use when read [...]
"reconnectBackoffMs": { "index": 69, "kind": "parameter", "displayName":
"Reconnect Backoff Ms", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "50",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The amount of time to
wait before attempting to reconnect to a giv [...]
- "recordMetadata": { "index": 70, "kind": "parameter", "displayName":
"Record Metadata", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the producer should store the
RecordMetadata results from sending to Kafka. T [...]
- "requestRequiredAcks": { "index": 71, "kind": "parameter", "displayName":
"Request Required Acks", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1",
"0", "1" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "all", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of acknowledgments [...]
- "requestTimeoutMs": { "index": 72, "kind": "parameter", "displayName":
"Request Timeout 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 amount of time the
broker will wait trying to meet the request. [...]
- "retries": { "index": 73, "kind": "parameter", "displayName": "Retries",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record that has failed to be sent due to a [...]
- "sendBufferBytes": { "index": 74, "kind": "parameter", "displayName":
"Send Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "131072",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Socket write buffer
size" },
- "useIterator": { "index": 75, "kind": "parameter", "displayName": "Use
Iterator", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether sending to kafka should send the
message body as a single record, or use a jav [...]
- "valueSerializer": { "index": 76, "kind": "parameter", "displayName":
"Value Serializer", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class fo [...]
- "workerPool": { "index": 77, "kind": "parameter", "displayName": "Worker
Pool", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "java.util.concurrent.ExecutorService", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknow [...]
- "workerPoolCoreSize": { "index": 78, "kind": "parameter", "displayName":
"Worker Pool Core Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Number of core threads
for the worker pool for continue routing E [...]
- "workerPoolMaxSize": { "index": 79, "kind": "parameter", "displayName":
"Worker Pool Max Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "20",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads for the worker pool for continue routing [...]
- "lazyStartProducer": { "index": 80, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "requestRequiredAcks": { "index": 70, "kind": "parameter", "displayName":
"Request Required Acks", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [ "all", "-1",
"0", "1" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "all", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The number of acknowledgments [...]
+ "requestTimeoutMs": { "index": 71, "kind": "parameter", "displayName":
"Request Timeout 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 amount of time the
broker will wait trying to meet the request. [...]
+ "retries": { "index": 72, "kind": "parameter", "displayName": "Retries",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Setting a value greater than zero will cause
the client to resend any record that has failed to be sent due to a [...]
+ "sendBufferBytes": { "index": 73, "kind": "parameter", "displayName":
"Send Buffer Bytes", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "131072",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Socket write buffer
size" },
+ "useIterator": { "index": 74, "kind": "parameter", "displayName": "Use
Iterator", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether sending to kafka should send the
message body as a single record, or use a jav [...]
+ "valueSerializer": { "index": 75, "kind": "parameter", "displayName":
"Value Serializer", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The serializer class fo [...]
+ "workerPool": { "index": 76, "kind": "parameter", "displayName": "Worker
Pool", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "java.util.concurrent.ExecutorService", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "To use a custom worker pool for continue
routing Exchange after kafka server has acknow [...]
+ "workerPoolCoreSize": { "index": 77, "kind": "parameter", "displayName":
"Worker Pool Core Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Number of core threads
for the worker pool for continue routing E [...]
+ "workerPoolMaxSize": { "index": 78, "kind": "parameter", "displayName":
"Worker Pool Max Size", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "20",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads for the worker pool for continue routing [...]
+ "lazyStartProducer": { "index": 79, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "recordMetadata": { "index": 80, "kind": "parameter", "displayName":
"Record Metadata", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the producer should store the
RecordMetadata results fro [...]
"kafkaClientFactory": { "index": 81, "kind": "parameter", "displayName":
"Kafka Client Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false,
"autowired": false, "secret": false, "description": "Factory to use for
creating org.apache.kafka.clients.consumer.KafkaConsumer and
org.apache.kafka.clients.producer.KafkaProducer instances. This allows to
configure a custo [...]
"synchronous": { "index": 82, "kind": "parameter", "displayName":
"Synchronous", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets whether synchronous processing should be
strictly used" },
"interceptorClasses": { "index": 83, "kind": "parameter", "displayName":
"Interceptor Classes", "group": "monitoring", "label": "common,monitoring",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets interceptors for producer or consumers.
Producer interceptors have to be cl [...]
diff --git a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
index 07c7388a613..c7f1398fdc7 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
@@ -530,7 +530,7 @@
"type": "java.lang.Boolean",
"description": "Whether the producer should store the RecordMetadata
results from sending to Kafka. The results are stored in a List containing the
RecordMetadata metadata's. The list is stored on a header with the key
KafkaConstants#KAFKA_RECORDMETA",
"sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration",
- "defaultValue": true
+ "defaultValue": false
},
{
"name": "camel.component.kafka.request-required-acks",
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 8c2afa6b29a..eadfc9b1cc7 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
@@ -623,13 +623,6 @@ public class KafkaComponentConfiguration
* backoff applies to all requests sent by the consumer to the broker.
*/
private Integer reconnectBackoffMs = 50;
- /**
- * Whether the producer should store the RecordMetadata results from
sending
- * to Kafka. The results are stored in a List containing the RecordMetadata
- * metadata's. The list is stored on a header with the key
- * KafkaConstants#KAFKA_RECORDMETA
- */
- private Boolean recordMetadata = true;
/**
* The number of acknowledgments the producer requires the leader to have
* received before considering a request complete. This controls the
@@ -713,6 +706,13 @@ public class KafkaComponentConfiguration
* it from KafkaProducer using asynchronous non-blocking processing.
*/
private Integer workerPoolMaxSize = 20;
+ /**
+ * Whether the producer should store the RecordMetadata results from
sending
+ * to Kafka. The results are stored in a List containing the RecordMetadata
+ * metadata's. The list is stored on a header with the key
+ * KafkaConstants#KAFKA_RECORDMETA
+ */
+ private Boolean recordMetadata = false;
/**
* Whether autowiring is enabled. This is used for automatic autowiring
* options (the option must be marked as autowired) by looking up in the
@@ -1520,14 +1520,6 @@ public class KafkaComponentConfiguration
this.reconnectBackoffMs = reconnectBackoffMs;
}
- public Boolean getRecordMetadata() {
- return recordMetadata;
- }
-
- public void setRecordMetadata(Boolean recordMetadata) {
- this.recordMetadata = recordMetadata;
- }
-
public String getRequestRequiredAcks() {
return requestRequiredAcks;
}
@@ -1600,6 +1592,14 @@ public class KafkaComponentConfiguration
this.workerPoolMaxSize = workerPoolMaxSize;
}
+ public Boolean getRecordMetadata() {
+ return recordMetadata;
+ }
+
+ public void setRecordMetadata(Boolean recordMetadata) {
+ this.recordMetadata = recordMetadata;
+ }
+
public Boolean getAutowiredEnabled() {
return autowiredEnabled;
}
