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: