You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/19 04:20:35 UTC
[camel-examples] 09/12: (chores) camel-resume-api-examples: adjust the initialization duration to match the launch script
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 f2469b66a8f7e4bfc601b3503e7e638629445d8f
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Aug 10 13:17:26 2022 +0200
(chores) camel-resume-api-examples: adjust the initialization duration to match the launch script
---
.../org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java | 3 +++
1 file changed, 3 insertions(+)
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 cd4efef8..11b9783b 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
@@ -17,6 +17,8 @@
package org.apache.camel.example.resume.strategies.kafka;
+import java.time.Duration;
+
import org.apache.camel.processor.resume.kafka.KafkaResumeStrategyConfiguration;
import org.apache.camel.processor.resume.kafka.KafkaResumeStrategyConfigurationBuilder;
import org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy;
@@ -36,6 +38,7 @@ public final class KafkaUtil {
.withBootstrapServers(bootStrapAddress)
.withTopic(kafkaTopic)
.withProducerProperty("max.block.ms", "10000")
+ .withMaxInitializationDuration(Duration.ofSeconds(5))
.build();
return new SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration);