[camel-examples] 09/12: (chores) camel-resume-api-examples: adjust the initialization duration to match the launch script

[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

commit f2469b66a8f7e4bfc601b3503e7e638629445d8f
Author: Otavio Rodolfo Piske <angusyo...@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);