Upgrade Camel to version 3.15.0

apache · Feb 10, 2022 · 12d3064 · 12d3064
1 parent 80e4782
commit 12d3064
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java b/...ets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ManualCommit.java
@@ -19,15 +19,15 @@
 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 {
 
     @Override
     public void process(Exchange exchange) throws Exception {
         KafkaManualCommit manual = exchange.getMessage().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
         if (manual != null) {
-            manual.commitSync();
+            manual.commit();
         }
     }
 }