commit da612e6563b6decff18625ad190f8454e75b9232
author Otavio Rodolfo Piske <angusyoung@gmail.com> Fri Aug 05 16:31:31 2022 +0200
committer Otavio Rodolfo Piske <orpiske@users.noreply.github.com> Mon Aug 08 10:42:51 2022 +0200
tree 5de0c8b4c657b298e4eec62614e1fcc020e18797
parent c49e824329163850c4ebcf234ee33d094bee2ddd

CAMEL-18356: consolidated the Kafka resume strategies

examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java

diff --git a/examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java b/examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java
index afee190..5d113d9 100644
--- a/examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java
+++ b/examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java
@@ -24,7 +24,7 @@
 import org.apache.camel.main.MainListener;
 import org.apache.camel.processor.resume.kafka.KafkaResumeStrategyConfiguration;
 import org.apache.camel.processor.resume.kafka.KafkaResumeStrategyConfigurationBuilder;
-import org.apache.camel.processor.resume.kafka.MultiNodeKafkaResumeStrategy;
+import org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy;
 import org.apache.camel.resume.Resumable;
 import org.apache.camel.resume.ResumeStrategy;
 import org.slf4j.Logger;
@@ -55,7 +55,7 @@
             main.getCamelContext().addService(clusterService);
 
             LOG.trace("Creating the strategy");
-            MultiNodeKafkaResumeStrategy<Resumable> resumeStrategy = newResumeStrategy();
+            SingleNodeKafkaResumeStrategy<Resumable> resumeStrategy = newResumeStrategy();
             main.getCamelContext().getRegistry().bind(ResumeStrategy.DEFAULT_NAME, resumeStrategy);
 
             LOG.trace("Creating the route");
@@ -93,7 +93,7 @@
         System.exit(0);
     }
 
-    private static MultiNodeKafkaResumeStrategy<Resumable> newResumeStrategy() {
+    private static SingleNodeKafkaResumeStrategy<Resumable> newResumeStrategy() {
         String bootStrapAddress = System.getProperty("bootstrap.address", "localhost:9092");
         String kafkaTopic = System.getProperty("resume.type.kafka.topic", "offsets");
 
@@ -103,6 +103,6 @@
                         .withTopic(kafkaTopic)
                         .build();
 
-        return new MultiNodeKafkaResumeStrategy(resumeStrategyConfiguration);
+        return new SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration);
     }
 }