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 3236a87bd030d1eac374c5cb0a53fce40e41f481 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Aug 10 13:18:02 2022 +0200 (chores) camel-resume-api-examples: avoid blocking the check route for too long --- .../apache/camel/example/resume/strategies/kafka/check/CheckRoute.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java index fbc3ab02..67db65fd 100644 --- a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java +++ b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java @@ -6,7 +6,7 @@ public class CheckRoute extends RouteBuilder { @Override public void configure() { - from("kafka:{{resume.type.kafka.topic}}?brokers={{bootstrap.address}}") + from("kafka:{{resume.type.kafka.topic}}?brokers={{bootstrap.address}}&maxBlockMs=5000&pollTimeoutMs=1000") .to("file:{{output.dir}}?fileName=summary.txt&fileExist=Append&appendChars=\n"); }
