This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 81b11eaf7b8 Regen for commit 0ee230f90a3dec7dcc44a93bc4ad8223d405c7c2
(#7594)
81b11eaf7b8 is described below
commit 81b11eaf7b8f8b60de5b6bd2fb8e461e2a55a92e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed May 11 22:32:22 2022 +0200
Regen for commit 0ee230f90a3dec7dcc44a93bc4ad8223d405c7c2 (#7594)
Signed-off-by: GitHub <nore...@github.com>
Co-authored-by: davsclaus <davscl...@users.noreply.github.com>
---
.../apache/camel/support/task/BackgroundTask.java | 4 +--
.../dsl/KafkaComponentBuilderFactory.java | 31 ++++++++++++++++++++++
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 30 +++++++++++++++++++++
3 files changed, 63 insertions(+), 2 deletions(-)
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/task/BackgroundTask.java
b/core/camel-support/src/main/java/org/apache/camel/support/task/BackgroundTask.java
index a1dcb1a2378..4909107e496 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/task/BackgroundTask.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/task/BackgroundTask.java
@@ -47,7 +47,7 @@ public class BackgroundTask implements BlockingTask {
/**
* Sets a time budget for the task
*
- * @param timeBudget the time budget
+ * @param timeBudget the time budget
*/
public BackgroundTaskBuilder withBudget(TimeBudget timeBudget) {
this.budget = timeBudget;
@@ -58,7 +58,7 @@ public class BackgroundTask implements BlockingTask {
/**
* Sets an executor service manager for managing the threads
*
- * @param service an instance of an executor service to use
+ * @param service an instance of an executor service to use
*/
public BackgroundTaskBuilder
withScheduledExecutor(ScheduledExecutorService service) {
this.service = service;
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 6b98abddd24..adcf8f56b31 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
@@ -784,6 +784,36 @@ public interface KafkaComponentBuilderFactory {
doSetProperty("createConsumerBackoffMaxAttempts",
createConsumerBackoffMaxAttempts);
return this;
}
+ /**
+ * Controls how to read messages written transactionally. If set to
+ * read_committed, consumer.poll() will only return transactional
+ * messages which have been committed. If set to read_uncommitted (the
+ * default), consumer.poll() will return all messages, even
+ * transactional messages which have been aborted. Non-transactional
+ * messages will be returned unconditionally in either mode. Messages
+ * will always be returned in offset order. Hence, in read_committed
+ * mode, consumer.poll() will only return messages up to the last
stable
+ * offset (LSO), which is the one less than the offset of the first
open
+ * transaction. In particular any messages appearing after messages
+ * belonging to ongoing transactions will be withheld until the
relevant
+ * transaction has been completed. As a result, read_committed
consumers
+ * will not be able to read up to the high watermark when there are in
+ * flight transactions. Further, when in read_committed the seekToEnd
+ * method will return the LSO.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: read_uncommitted
+ * Group: consumer (advanced)
+ *
+ * @param isolationLevel the value to set
+ * @return the dsl builder
+ */
+ default KafkaComponentBuilder isolationLevel(
+ java.lang.String isolationLevel) {
+ doSetProperty("isolationLevel", isolationLevel);
+ return this;
+ }
/**
* Factory to use for creating KafkaManualCommit instances. This allows
* to plugin a custom factory to create custom KafkaManualCommit
@@ -2089,6 +2119,7 @@ public interface KafkaComponentBuilderFactory {
case "valueDeserializer":
getOrCreateConfiguration((KafkaComponent)
component).setValueDeserializer((java.lang.String) value); return true;
case "createConsumerBackoffInterval": ((KafkaComponent)
component).setCreateConsumerBackoffInterval((long) value); return true;
case "createConsumerBackoffMaxAttempts": ((KafkaComponent)
component).setCreateConsumerBackoffMaxAttempts((int) value); return true;
+ case "isolationLevel": getOrCreateConfiguration((KafkaComponent)
component).setIsolationLevel((java.lang.String) value); return true;
case "kafkaManualCommitFactory": ((KafkaComponent)
component).setKafkaManualCommitFactory((org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory)
value); return true;
case "pollExceptionStrategy": ((KafkaComponent)
component).setPollExceptionStrategy((org.apache.camel.component.kafka.PollExceptionStrategy)
value); return true;
case "subscribeConsumerBackoffInterval": ((KafkaComponent)
component).setSubscribeConsumerBackoffInterval((long) 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 31ce4492994..c174ae8135c 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
@@ -1882,6 +1882,36 @@ public interface KafkaEndpointBuilderFactory {
doSetProperty("exchangePattern", exchangePattern);
return this;
}
+ /**
+ * Controls how to read messages written transactionally. If set to
+ * read_committed, consumer.poll() will only return transactional
+ * messages which have been committed. If set to read_uncommitted (the
+ * default), consumer.poll() will return all messages, even
+ * transactional messages which have been aborted. Non-transactional
+ * messages will be returned unconditionally in either mode. Messages
+ * will always be returned in offset order. Hence, in read_committed
+ * mode, consumer.poll() will only return messages up to the last
stable
+ * offset (LSO), which is the one less than the offset of the first
open
+ * transaction. In particular any messages appearing after messages
+ * belonging to ongoing transactions will be withheld until the
relevant
+ * transaction has been completed. As a result, read_committed
consumers
+ * will not be able to read up to the high watermark when there are in
+ * flight transactions. Further, when in read_committed the seekToEnd
+ * method will return the LSO.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: read_uncommitted
+ * Group: consumer (advanced)
+ *
+ * @param isolationLevel the value to set
+ * @return the dsl builder
+ */
+ default AdvancedKafkaEndpointConsumerBuilder isolationLevel(
+ String isolationLevel) {
+ doSetProperty("isolationLevel", isolationLevel);
+ return this;
+ }
/**
* Factory to use for creating KafkaManualCommit instances. This allows
* to plugin a custom factory to create custom KafkaManualCommit
