(camel-quarkus-examples) branch camel-quarkus-main updated: Fix timer counter not being populated in Kafka example #8729

[aldettinger]

This is an automated email from the ASF dual-hosted git repository.

aldettinger pushed a commit to branch camel-quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus-examples.git


The following commit(s) were added to refs/heads/camel-quarkus-main by this 
push:
     new 125cf586 Fix timer counter not being populated in Kafka example #8729
125cf586 is described below

commit 125cf5868efc06490b183b6877856485c326c8a9
Author: aldettinger <aldettin...@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 <b...@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;
         });
     }
 }