This is an automated email from the ASF dual-hosted git repository.
Croway pushed a commit to branch 4.18.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/4.18.x by this push:
new 748cb15b0 chore: update header names for Camel 4.18.3 header renames
748cb15b0 is described below
commit 748cb15b01a4bf136eae6e8238440445e4666fe5
Author: Croway <[email protected]>
AuthorDate: Fri Jun 26 14:59:04 2026 +0200
chore: update header names for Camel 4.18.3 header renames
---
kamelets/elasticsearch-index-sink.kamelet.yaml | 16 ++++++++--------
...kafka-apicurio-registry-not-secured-sink.kamelet.yaml | 8 ++++----
kamelets/kafka-azure-schema-registry-sink.kamelet.yaml | 8 ++++----
...kafka-not-secured-apicurio-registry-sink.kamelet.yaml | 8 ++++----
kamelets/kafka-sink.kamelet.yaml | 8 ++++----
kamelets/opensearch-index-sink.kamelet.yaml | 16 ++++++++--------
kamelets/salesforce-delete-sink.kamelet.yaml | 8 ++++----
kamelets/salesforce-update-sink.kamelet.yaml | 8 ++++----
kamelets/set-kafka-key-action.kamelet.yaml | 2 +-
.../kamelets/elasticsearch-index-sink.kamelet.yaml | 16 ++++++++--------
...kafka-apicurio-registry-not-secured-sink.kamelet.yaml | 8 ++++----
.../kafka-azure-schema-registry-sink.kamelet.yaml | 8 ++++----
...kafka-not-secured-apicurio-registry-sink.kamelet.yaml | 8 ++++----
.../src/main/resources/kamelets/kafka-sink.kamelet.yaml | 8 ++++----
.../kamelets/opensearch-index-sink.kamelet.yaml | 16 ++++++++--------
.../kamelets/salesforce-delete-sink.kamelet.yaml | 8 ++++----
.../kamelets/salesforce-update-sink.kamelet.yaml | 8 ++++----
.../resources/kamelets/set-kafka-key-action.kamelet.yaml | 2 +-
.../src/test/resources/kafka/kafka-router-pipe.it.yaml | 4 ++--
.../src/test/resources/kafka/kafka-source-pipe.it.yaml | 6 +++---
20 files changed, 87 insertions(+), 87 deletions(-)
diff --git a/kamelets/elasticsearch-index-sink.kamelet.yaml
b/kamelets/elasticsearch-index-sink.kamelet.yaml
index cf4b1c7d0..8cbb3d0e7 100644
--- a/kamelets/elasticsearch-index-sink.kamelet.yaml
+++ b/kamelets/elasticsearch-index-sink.kamelet.yaml
@@ -97,27 +97,27 @@ spec:
steps:
- choice:
when:
- - simple: "${header[indexId]}"
+ - simple: "${header[CamelElasticsearchIndexId]}"
steps:
- setHeader:
- name: "indexId"
- simple: "${header[indexId]}"
+ name: "CamelElasticsearchIndexId"
+ simple: "${header[CamelElasticsearchIndexId]}"
- simple: "${header[ce-indexid]}"
steps:
- setHeader:
- name: "indexId"
+ name: "CamelElasticsearchIndexId"
simple: "${header[ce-indexid]}"
- choice:
when:
- - simple: "${header[indexName]}"
+ - simple: "${header[CamelElasticsearchIndexName]}"
steps:
- setHeader:
- name: "indexName"
- simple: "${header[indexName]}"
+ name: "CamelElasticsearchIndexName"
+ simple: "${header[CamelElasticsearchIndexName]}"
- simple: "${header[ce-indexname]}"
steps:
- setHeader:
- name: "indexName"
+ name: "CamelElasticsearchIndexName"
simple: "${header[ce-indexname]}"
- unmarshal:
json: {}
diff --git a/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
b/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
index c5a525b32..2c4079d89 100644
--- a/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
+++ b/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
@@ -73,24 +73,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git a/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
b/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
index fa690045b..ea8b1d6e5 100644
--- a/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
@@ -97,24 +97,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git a/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
b/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
index ac21a118f..90ac637e8 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
@@ -110,24 +110,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git a/kamelets/kafka-sink.kamelet.yaml b/kamelets/kafka-sink.kamelet.yaml
index 97193aa06..d45264041 100644
--- a/kamelets/kafka-sink.kamelet.yaml
+++ b/kamelets/kafka-sink.kamelet.yaml
@@ -122,24 +122,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git a/kamelets/opensearch-index-sink.kamelet.yaml
b/kamelets/opensearch-index-sink.kamelet.yaml
index 1639d44b0..9f533ecad 100644
--- a/kamelets/opensearch-index-sink.kamelet.yaml
+++ b/kamelets/opensearch-index-sink.kamelet.yaml
@@ -97,27 +97,27 @@ spec:
steps:
- choice:
when:
- - simple: "${header[indexId]}"
+ - simple: "${header[CamelOpensearchIndexId]}"
steps:
- setHeader:
- name: "indexId"
- simple: "${header[indexId]}"
+ name: "CamelOpensearchIndexId"
+ simple: "${header[CamelOpensearchIndexId]}"
- simple: "${header[ce-indexid]}"
steps:
- setHeader:
- name: "indexId"
+ name: "CamelOpensearchIndexId"
simple: "${header[ce-indexid]}"
- choice:
when:
- - simple: "${header[indexName]}"
+ - simple: "${header[CamelOpensearchIndexName]}"
steps:
- setHeader:
- name: "indexName"
- simple: "${header[indexName]}"
+ name: "CamelOpensearchIndexName"
+ simple: "${header[CamelOpensearchIndexName]}"
- simple: "${header[ce-indexname]}"
steps:
- setHeader:
- name: "indexName"
+ name: "CamelOpensearchIndexName"
simple: "${header[ce-indexname]}"
- unmarshal:
json: {}
diff --git a/kamelets/salesforce-delete-sink.kamelet.yaml
b/kamelets/salesforce-delete-sink.kamelet.yaml
index b5833cef0..842f31bde 100644
--- a/kamelets/salesforce-delete-sink.kamelet.yaml
+++ b/kamelets/salesforce-delete-sink.kamelet.yaml
@@ -99,16 +99,16 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
jsonpath: "$['sObjectId']"
- setHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
jsonpath: "$['sObjectName']"
- setBody:
simple: "${null}"
- to:
uri: "{{local-delete-salesforce}}:deleteSObject"
- removeHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
- removeHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
diff --git a/kamelets/salesforce-update-sink.kamelet.yaml
b/kamelets/salesforce-update-sink.kamelet.yaml
index a18c929dd..cbe5484c1 100644
--- a/kamelets/salesforce-update-sink.kamelet.yaml
+++ b/kamelets/salesforce-update-sink.kamelet.yaml
@@ -93,10 +93,10 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
jsonpath: "$.sObjectId"
- setHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
jsonpath: "$.sObjectName"
- transform:
jsonpath: "$.payload"
@@ -107,6 +107,6 @@ spec:
parameters:
rawPayload: "true"
- removeHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
- removeHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
diff --git a/kamelets/set-kafka-key-action.kamelet.yaml
b/kamelets/set-kafka-key-action.kamelet.yaml
index 4c8d378cc..2d6e44441 100644
--- a/kamelets/set-kafka-key-action.kamelet.yaml
+++ b/kamelets/set-kafka-key-action.kamelet.yaml
@@ -52,7 +52,7 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header.{{headerName}}}"
- choice:
precondition: true
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
index cf4b1c7d0..8cbb3d0e7 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
@@ -97,27 +97,27 @@ spec:
steps:
- choice:
when:
- - simple: "${header[indexId]}"
+ - simple: "${header[CamelElasticsearchIndexId]}"
steps:
- setHeader:
- name: "indexId"
- simple: "${header[indexId]}"
+ name: "CamelElasticsearchIndexId"
+ simple: "${header[CamelElasticsearchIndexId]}"
- simple: "${header[ce-indexid]}"
steps:
- setHeader:
- name: "indexId"
+ name: "CamelElasticsearchIndexId"
simple: "${header[ce-indexid]}"
- choice:
when:
- - simple: "${header[indexName]}"
+ - simple: "${header[CamelElasticsearchIndexName]}"
steps:
- setHeader:
- name: "indexName"
- simple: "${header[indexName]}"
+ name: "CamelElasticsearchIndexName"
+ simple: "${header[CamelElasticsearchIndexName]}"
- simple: "${header[ce-indexname]}"
steps:
- setHeader:
- name: "indexName"
+ name: "CamelElasticsearchIndexName"
simple: "${header[ce-indexname]}"
- unmarshal:
json: {}
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
index c5a525b32..2c4079d89 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
@@ -73,24 +73,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
index fa690045b..ea8b1d6e5 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
@@ -97,24 +97,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
index ac21a118f..90ac637e8 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
@@ -110,24 +110,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
index 97193aa06..d45264041 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
@@ -122,24 +122,24 @@ spec:
- simple: "${header[key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header[ce-key]}"
- choice:
when:
- simple: "${header[partition-key]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[partition-key]}"
- simple: "${header[ce-partitionkey]}"
steps:
- setHeader:
- name: kafka.PARTITION_KEY
+ name: CamelKafkaPartitionKey
simple: "${header[ce-partitionkey]}"
- to:
uri: "kafka:{{topic}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/opensearch-index-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/opensearch-index-sink.kamelet.yaml
index 1639d44b0..9f533ecad 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/opensearch-index-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/opensearch-index-sink.kamelet.yaml
@@ -97,27 +97,27 @@ spec:
steps:
- choice:
when:
- - simple: "${header[indexId]}"
+ - simple: "${header[CamelOpensearchIndexId]}"
steps:
- setHeader:
- name: "indexId"
- simple: "${header[indexId]}"
+ name: "CamelOpensearchIndexId"
+ simple: "${header[CamelOpensearchIndexId]}"
- simple: "${header[ce-indexid]}"
steps:
- setHeader:
- name: "indexId"
+ name: "CamelOpensearchIndexId"
simple: "${header[ce-indexid]}"
- choice:
when:
- - simple: "${header[indexName]}"
+ - simple: "${header[CamelOpensearchIndexName]}"
steps:
- setHeader:
- name: "indexName"
- simple: "${header[indexName]}"
+ name: "CamelOpensearchIndexName"
+ simple: "${header[CamelOpensearchIndexName]}"
- simple: "${header[ce-indexname]}"
steps:
- setHeader:
- name: "indexName"
+ name: "CamelOpensearchIndexName"
simple: "${header[ce-indexname]}"
- unmarshal:
json: {}
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/salesforce-delete-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/salesforce-delete-sink.kamelet.yaml
index b5833cef0..842f31bde 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/salesforce-delete-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/salesforce-delete-sink.kamelet.yaml
@@ -99,16 +99,16 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
jsonpath: "$['sObjectId']"
- setHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
jsonpath: "$['sObjectName']"
- setBody:
simple: "${null}"
- to:
uri: "{{local-delete-salesforce}}:deleteSObject"
- removeHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
- removeHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
index a18c929dd..cbe5484c1 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
@@ -93,10 +93,10 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
jsonpath: "$.sObjectId"
- setHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
jsonpath: "$.sObjectName"
- transform:
jsonpath: "$.payload"
@@ -107,6 +107,6 @@ spec:
parameters:
rawPayload: "true"
- removeHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
- removeHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/set-kafka-key-action.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/set-kafka-key-action.kamelet.yaml
index 4c8d378cc..2d6e44441 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/set-kafka-key-action.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/set-kafka-key-action.kamelet.yaml
@@ -52,7 +52,7 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: kafka.KEY
+ name: CamelKafkaKey
simple: "${header.{{headerName}}}"
- choice:
precondition: true
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.it.yaml
index 82fed4d88..820c67016 100644
---
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.it.yaml
@@ -56,9 +56,9 @@ actions:
fork: true
GET:
parameters:
- - name: "kafka.TOPIC"
+ - name: "CamelKafkaTopic"
value: "${kafka.topic}"
- - name: "kafka.TIMESTAMP"
+ - name: "CamelKafkaTimestamp"
value: "${timestamp}"
- name: "message"
value: "citrus:urlEncode(${kafka.message})"
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.it.yaml
index fa08d0ab8..1836398fd 100644
---
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.it.yaml
@@ -86,11 +86,11 @@ actions:
headers:
- name: event-source
value: "${kafka.source}"
- - name: kafka.TOPIC
+ - name: CamelKafkaTopic
value: "${kafka.topic}"
- - name: kafka.KEY
+ - name: CamelKafkaKey
value: "${kafka.message.key}"
- - name: kafka.PARTITION
+ - name: CamelKafkaPartition
value: "0"
body:
data: |
