[camel-examples] 01/12: (chores) camel-resume-api-examples: avoid blocking for too long by default

[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 907be061cba7c3db54f346d99b344db32b492db3
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Aug 9 10:09:30 2022 +0200

    (chores) camel-resume-api-examples: avoid blocking for too long by default
---
 .../java/org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java | 1 +
 1 file changed, 1 insertion(+)

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 f943c2cc..68c97cc4 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
@@ -36,6 +36,7 @@ public final class KafkaUtil {
                 KafkaResumeStrategyConfigurationBuilder.newBuilder()
                         .withBootstrapServers(bootStrapAddress)
                         .withTopic(kafkaTopic)
+                        .withProducerProperty("max.block.ms", "10000")
                         .build();
 
         return new 
SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration);