This is an automated email from the ASF dual-hosted git repository.
oscerd pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new c81faf789 chore: use application headers in Kafka router tests (#3113)
c81faf789 is described below
commit c81faf789b94e884c0130d7478b6122cacc4f717
Author: Federico Mariani <[email protected]>
AuthorDate: Fri Oct 23 09:59:22 2026 +0200
chore: use application headers in Kafka router tests (#3113)
Co-authored-by: Federico Mariani <[email protected]>
---
.../src/test/resources/kafka/kafka-router-route.citrus.it.yaml | 4 ++--
.../src/test/resources/kafka/kafka-router-route.yaml | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.citrus.it.yaml
index aa44051fd..b40519bdc 100644
---
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.citrus.it.yaml
@@ -52,9 +52,9 @@ actions:
fork: true
GET:
parameters:
- - name: "kafka.TOPIC"
+ - name: "topic"
value: "${kafka.topic}"
- - name: "kafka.TIMESTAMP"
+ - name: "timestamp"
value: "${timestamp}"
- name: "message"
value: "citrus:urlEncode(${kafka.message})"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.yaml
index e3ca1f6f6..db7b04ba9 100644
---
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-route.yaml
@@ -26,8 +26,8 @@
parameters:
topicFormat: $[topic]_$[timestamp]
timestampFormat: YYYY-MM-dd
- timestampHeaderName: kafka.TIMESTAMP
- topicHeaderName: kafka.TOPIC
+ timestampHeaderName: timestamp
+ topicHeaderName: topic
- to:
uri: "kamelet:set-body-action"
parameters:
