[camel-kamelets] 02/02: Upgrade Camel to version 3.15.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch camel-3.15.0
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit c3ac0d2e9b52813c9ce1a28133bc11f4c74eb46d
Author: Andrea Cosentino <anco...@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();
         }
     }
 }