You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/02/10 09:29:16 UTC
[camel-kamelets] branch main updated (2975bdc -> 12d3064)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.
from 2975bdc Kamelets Catalog: Fixed tests
new 80e4782 Upgrade Camel to version 3.15.0
new 12d3064 Upgrade Camel to version 3.15.0
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java | 4 ++--
pom.xml | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
[camel-kamelets] 01/02: Upgrade Camel to version 3.15.0
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 80e47821f59aa3b4b343869951ff1e388e67b725
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Feb 10 08:41:49 2022 +0100
Upgrade Camel to version 3.15.0
---
pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pom.xml b/pom.xml
index ed53de2..2fb671b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -57,7 +57,7 @@
<maven-groovy-plugin.version>2.1.1</maven-groovy-plugin.version>
<apache-rat-plugin.version>0.13</apache-rat-plugin.version>
- <camel.version>3.14.0</camel.version>
+ <camel.version>3.15.0</camel.version>
<slf4j.version>1.7.30</slf4j.version>
<log4j.version>2.17.1</log4j.version>
<jackson.version>2.12.5</jackson.version>
[camel-kamelets] 02/02: Upgrade Camel to version 3.15.0
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 12d30645fbcf9530d0da56a2593b982a227b024a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Feb 10 08:45:04 2022 +0100
Upgrade Camel to version 3.15.0
---
.../org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java
index 14856b0..3fa21eb 100644
--- a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java
+++ b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java
@@ -19,7 +19,7 @@ package org.apache.camel.kamelets.utils.transform.kafka;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.component.kafka.KafkaConstants;
-import org.apache.camel.component.kafka.KafkaManualCommit;
+import org.apache.camel.component.kafka.consumer.KafkaManualCommit;
public class ManualCommit implements Processor {
@@ -27,7 +27,7 @@ public class ManualCommit implements Processor {
public void process(Exchange exchange) throws Exception {
KafkaManualCommit manual = exchange.getMessage().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
if (manual != null) {
- manual.commitSync();
+ manual.commit();
}
}
}