This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus-examples.git
commit 711f46034cde1489cd0c12d3a89519176d931795 Author: aldettinger <[email protected]> AuthorDate: Mon Jun 8 18:15:59 2026 +0200 Fix timer counter not being populated in Kafka example #8729 Co-authored-by: Bob Shell <[email protected]> Generated with Bob Shell v1.0.4 --- .gitignore | 2 ++ kafka/src/main/java/org/acme/kafka/Routes.java | 2 +- kafka/src/test/java/org/acme/kafka/KafkaTest.java | 10 +++++++++- 3 files changed, 12 insertions(+), 2 deletions(-) diff --git a/.gitignore b/.gitignore index 52998f32..2d257580 100644 --- a/.gitignore +++ b/.gitignore @@ -48,3 +48,5 @@ flight.* train.* app.* +# AI assistants +.bob diff --git a/kafka/src/main/java/org/acme/kafka/Routes.java b/kafka/src/main/java/org/acme/kafka/Routes.java index de534e55..dd5e672e 100644 --- a/kafka/src/main/java/org/acme/kafka/Routes.java +++ b/kafka/src/main/java/org/acme/kafka/Routes.java @@ -25,7 +25,7 @@ public class Routes extends RouteBuilder { @Override public void configure() throws Exception { // produces messages to kafka - from("timer:foo?period={{timer.period}}&delay={{timer.delay}}") + from("timer:foo?period={{timer.period}}&delay={{timer.delay}}&includeMetadata=true") .routeId("FromTimer2Kafka") .setBody().simple("Message #${exchangeProperty.CamelTimerCounter}") .to("kafka:{{kafka.topic.name}}") diff --git a/kafka/src/test/java/org/acme/kafka/KafkaTest.java b/kafka/src/test/java/org/acme/kafka/KafkaTest.java index 3854bf8a..63cc694b 100644 --- a/kafka/src/test/java/org/acme/kafka/KafkaTest.java +++ b/kafka/src/test/java/org/acme/kafka/KafkaTest.java @@ -17,6 +17,8 @@ package org.acme.kafka; import java.util.concurrent.TimeUnit; +import java.util.regex.Matcher; +import java.util.regex.Pattern; import io.quarkus.test.junit.QuarkusTest; import io.restassured.RestAssured; @@ -29,9 +31,15 @@ public class KafkaTest { @Test public void testKafka() { + Pattern pattern = Pattern.compile("Message #(\\d+)"); + await().atMost(10, TimeUnit.SECONDS).until(() -> { String message = RestAssured.get("/example").asString(); - return message != null && message.contains("Message #"); + if (message == null) { + return false; + } + Matcher matcher = pattern.matcher(message); + return matcher.find() && Integer.parseInt(matcher.group(1)) > 0; }); } }
