(camel-quarkus-examples) 09/33: Fix timer counter not being populated in Kafka example #8729

[ja...@apache.org]

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 <al...@gmail.com>
AuthorDate: Mon Jun 8 18:15:59 2026 +0200

    Fix timer counter not being populated in Kafka example #8729
    
    Co-authored-by: Bob Shell <bo...@bob-shell.dev>
    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;
         });
     }
 }