[camel-examples] branch main updated: CAMEL-18356: consolidated the Kafka resume strategies

[orpiske]

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

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-examples.git


The following commit(s) were added to refs/heads/main by this push:
     new da612e65 CAMEL-18356: consolidated the Kafka resume strategies
da612e65 is described below

commit da612e6563b6decff18625ad190f8454e75b9232
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Aug 5 16:31:31 2022 +0200

    CAMEL-18356: consolidated the Kafka resume strategies
---
 .../resume/fileset/clusterized/main/ClusterizedListener.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 afee1903..5d113d90 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.BaseMainSupport;
 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 @@ class ClusterizedListener implements MainListener {
             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 @@ class ClusterizedListener implements MainListener {
         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 @@ class ClusterizedListener implements MainListener {
                         .withTopic(kafkaTopic)
                         .build();
 
-        return new MultiNodeKafkaResumeStrategy(resumeStrategyConfiguration);
+        return new 
SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration);
     }
 }