This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.18.x by this push:
new a6d804e218e CAMEL-18527: Regen
a6d804e218e is described below
commit a6d804e218e969191d3cc7ab77385059cffd43ab
Author: Claus Ibsen <[email protected]>
AuthorDate: Thu Sep 22 12:38:47 2022 +0200
CAMEL-18527: Regen
---
.../org/apache/camel/catalog/components/kafka.json | 2 +
.../dsl/KafkaComponentBuilderFactory.java | 22 +++++++++++
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 43 ++++++++++++++++++++++
3 files changed, 67 insertions(+)
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 804546c4a9b..9fcbbcb3d68 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
@@ -66,6 +66,7 @@
"pollExceptionStrategy": { "kind": "property", "displayName": "Poll
Exception Strategy", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.PollExceptionStrategy", "deprecated": false,
"autowired": true, "secret": false, "description": "To use a custom strategy
with the consumer to control how to handle exceptions thrown from the Kafka
broker while pooling messages." },
"subscribeConsumerBackoffInterval": { "kind": "property", "displayName":
"Subscribe Consumer Backoff Interval", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5000,
"description": "The delay in millis seconds to wait before trying again to
subscribe to the kafka broker." },
"subscribeConsumerBackoffMaxAttempts": { "kind": "property",
"displayName": "Subscribe Consumer Backoff Max Attempts", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "description": "Maximum number the kafka consumer will attempt
to subscribe to the kafka broker, before eventually giving up and failing.
Error during subscribing the consumer to the kafka top [...]
+ "batchWithIndividualHeaders": { "kind": "property", "displayName": "Batch
With Individual Headers", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "If this feature is
enabled and a single element of a batch is an Exchang [...]
"bufferMemorySize": { "kind": "property", "displayName": "Buffer Memory
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "33554432", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The total bytes of memory the producer can use
to buffer records waiting to be [...]
"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, "autowired": false, "secret": false,
"defaultValue": "none", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This parameter allows you to specify the [...]
"connectionMaxIdleMs": { "kind": "property", "displayName": "Connection
Max Idle Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": 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 [...]
@@ -187,6 +188,7 @@
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
"isolationLevel": { "kind": "parameter", "displayName": "Isolation Level",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [
"read_uncommitted", "read_committed" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "read_uncommitted",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Contro [...]
"kafkaManualCommitFactory": { "kind": "parameter", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory",
"deprecated": false, "autowired": false, "secret": false, "description":
"Factory to use for creating KafkaManualCommit instances. This allows to plugin
a custom factory to create custom KafkaManualCommit insta [...]
+ "batchWithIndividualHeaders": { "kind": "parameter", "displayName": "Batch
With Individual Headers", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "If this feature is
enabled and a single element of a batch is an Exchan [...]
"bufferMemorySize": { "kind": "parameter", "displayName": "Buffer Memory
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "33554432", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The total bytes of memory the producer can use
to buffer records waiting to b [...]
"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, "autowired": false, "secret": false,
"defaultValue": "none", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This parameter allows you to specify th [...]
"connectionMaxIdleMs": { "kind": "parameter", "displayName": "Connection
Max Idle Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": 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 thi [...]
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
index 8d55e07640c..9a08736e9db 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
@@ -891,6 +891,27 @@ public interface KafkaComponentBuilderFactory {
doSetProperty("subscribeConsumerBackoffMaxAttempts",
subscribeConsumerBackoffMaxAttempts);
return this;
}
+ /**
+ * If this feature is enabled and a single element of a batch is an
+ * Exchange or Message, the producer will generate individual kafka
+ * header values for it by using the batch Message to determine the
+ * values. Normal behaviour consists in always using the same header
+ * values (which are determined by the parent Exchange which contains
+ * the Iterable or Iterator).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param batchWithIndividualHeaders the value to set
+ * @return the dsl builder
+ */
+ default KafkaComponentBuilder batchWithIndividualHeaders(
+ boolean batchWithIndividualHeaders) {
+ doSetProperty("batchWithIndividualHeaders",
batchWithIndividualHeaders);
+ return this;
+ }
/**
* The total bytes of memory the producer can use to buffer records
* waiting to be sent to the server. If records are sent faster than
@@ -2128,6 +2149,7 @@ public interface KafkaComponentBuilderFactory {
case "pollExceptionStrategy": ((KafkaComponent)
component).setPollExceptionStrategy((org.apache.camel.component.kafka.PollExceptionStrategy)
value); return true;
case "subscribeConsumerBackoffInterval": ((KafkaComponent)
component).setSubscribeConsumerBackoffInterval((long) value); return true;
case "subscribeConsumerBackoffMaxAttempts": ((KafkaComponent)
component).setSubscribeConsumerBackoffMaxAttempts((int) value); return true;
+ case "batchWithIndividualHeaders":
getOrCreateConfiguration((KafkaComponent)
component).setBatchWithIndividualHeaders((boolean) value); return true;
case "bufferMemorySize": getOrCreateConfiguration((KafkaComponent)
component).setBufferMemorySize((java.lang.Integer) value); return true;
case "compressionCodec": getOrCreateConfiguration((KafkaComponent)
component).setCompressionCodec((java.lang.String) value); return true;
case "connectionMaxIdleMs":
getOrCreateConfiguration((KafkaComponent)
component).setConnectionMaxIdleMs((java.lang.Integer) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
index 644a37d8324..7edc7741426 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
@@ -2229,6 +2229,49 @@ public interface KafkaEndpointBuilderFactory {
doSetProperty("shutdownTimeout", shutdownTimeout);
return this;
}
+ /**
+ * If this feature is enabled and a single element of a batch is an
+ * Exchange or Message, the producer will generate individual kafka
+ * header values for it by using the batch Message to determine the
+ * values. Normal behaviour consists in always using the same header
+ * values (which are determined by the parent Exchange which contains
+ * the Iterable or Iterator).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param batchWithIndividualHeaders the value to set
+ * @return the dsl builder
+ */
+ default KafkaEndpointProducerBuilder batchWithIndividualHeaders(
+ boolean batchWithIndividualHeaders) {
+ doSetProperty("batchWithIndividualHeaders",
batchWithIndividualHeaders);
+ return this;
+ }
+ /**
+ * If this feature is enabled and a single element of a batch is an
+ * Exchange or Message, the producer will generate individual kafka
+ * header values for it by using the batch Message to determine the
+ * values. Normal behaviour consists in always using the same header
+ * values (which are determined by the parent Exchange which contains
+ * the Iterable or Iterator).
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param batchWithIndividualHeaders the value to set
+ * @return the dsl builder
+ */
+ default KafkaEndpointProducerBuilder batchWithIndividualHeaders(
+ String batchWithIndividualHeaders) {
+ doSetProperty("batchWithIndividualHeaders",
batchWithIndividualHeaders);
+ return this;
+ }
/**
* The total bytes of memory the producer can use to buffer records
* waiting to be sent to the server. If records are sent faster than
