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
commit f2664dce9233f9cdf8adc7861cf07f37cd1f7b18 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Tue Aug 9 17:41:21 2022 +0200 (chores) camel-resume-api-examples: use the default strategy builder as part of CAMEL-18362 --- .../camel/example/resume/strategies/kafka/KafkaUtil.java | 15 --------------- .../camel/example/resume/file/offset/main/MainApp.java | 2 +- 2 files changed, 1 insertion(+), 16 deletions(-) diff --git a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java index 68c97cc4..cd4efef8 100644 --- a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java +++ b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java @@ -20,7 +20,6 @@ package org.apache.camel.example.resume.strategies.kafka; import org.apache.camel.processor.resume.kafka.KafkaResumeStrategyConfiguration; import org.apache.camel.processor.resume.kafka.KafkaResumeStrategyConfigurationBuilder; import org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy; -import org.apache.camel.resume.Cacheable; import org.apache.camel.resume.Resumable; public final class KafkaUtil { @@ -41,18 +40,4 @@ public final class KafkaUtil { return new SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration); } - - public static SingleNodeKafkaResumeStrategy<Resumable> getMinimizingStrategy() { - String bootStrapAddress = System.getProperty("bootstrap.address", "localhost:9092"); - String kafkaTopic = System.getProperty("resume.type.kafka.topic", "offsets"); - - KafkaResumeStrategyConfiguration resumeStrategyConfiguration = - KafkaResumeStrategyConfigurationBuilder.newBuilder() - .withCacheFillPolicy(Cacheable.FillPolicy.MINIMIZING) - .withBootstrapServers(bootStrapAddress) - .withTopic(kafkaTopic) - .build(); - - return new SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration); - } } diff --git a/examples/resume-api/resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/main/MainApp.java b/examples/resume-api/resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/main/MainApp.java index 5bc8271d..cfe99abe 100644 --- a/examples/resume-api/resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/main/MainApp.java +++ b/examples/resume-api/resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/main/MainApp.java @@ -43,7 +43,7 @@ public class MainApp { int batchSize = Integer.valueOf(tmp); CountDownLatch latch = new CountDownLatch(batchSize); - SingleNodeKafkaResumeStrategy<Resumable> resumeStrategy = KafkaUtil.getMinimizingStrategy(); + SingleNodeKafkaResumeStrategy<Resumable> resumeStrategy = KafkaUtil.getDefaultStrategy(); RouteBuilder routeBuilder = new LargeFileRouteBuilder(resumeStrategy, new CaffeineCache<>(1), latch); main.configure().addRoutesBuilder(routeBuilder);
