You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/05/11 20:32:29 UTC
[camel] branch main updated: Regen for commit 0ee230f90a3dec7dcc44a93bc4ad8223d405c7c2 (#7594)
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] <41...@users.noreply.github.com>
AuthorDate: Wed May 11 22:32:22 2022 +0200
Regen for commit 0ee230f90a3dec7dcc44a93bc4ad8223d405c7c2 (#7594)
Signed-off-by: GitHub <no...@github.com>
Co-authored-by: davsclaus <da...@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