This is an automated email from the ASF dual-hosted git repository.
oscerd pushed a commit to branch 4.22.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/4.22.x by this push:
new 78c648f9c chore: align packaged Salesforce and Kafka test headers
(#3112)
78c648f9c is described below
commit 78c648f9cb1281b34706d5e51251e63704b2d0a8
Author: Federico Mariani <[email protected]>
AuthorDate: Fri Oct 23 09:59:15 2026 +0200
chore: align packaged Salesforce and Kafka test headers (#3112)
Co-authored-by: Federico Mariani <[email protected]>
---
.../kamelets/salesforce-delete-sink.kamelet.yaml | 12 ++++++++----
.../kamelets/salesforce-update-sink.kamelet.yaml | 18 ++++++++++++------
.../resources/kafka/kafka-router-pipe.citrus.it.yaml | 4 ++--
.../src/test/resources/kafka/kafka-router-pipe.yaml | 4 ++--
4 files changed, 24 insertions(+), 14 deletions(-)
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 2cecb4bc5..d329fce7f 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,20 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: CamelSalesforceId
- jsonpath: "$['sObjectId']"
+ name: CamelSalesforceSObjectId
+ expression:
+ jsonpath:
+ expression: "$['sObjectId']"
- setHeader:
name: CamelSalesforceSObjectName
- jsonpath: "$['sObjectName']"
+ expression:
+ jsonpath:
+ expression: "$['sObjectName']"
- setBody:
simple: "${null}"
- to:
uri: "{{local-delete-salesforce}}:deleteSObject"
- removeHeader:
- name: CamelSalesforceId
+ name: CamelSalesforceSObjectId
- removeHeader:
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 d3841e1d5..15117236b 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,13 +93,19 @@ spec:
uri: kamelet:source
steps:
- setHeader:
- name: CamelSalesforceId
- jsonpath: "$.sObjectId"
+ name: CamelSalesforceSObjectId
+ expression:
+ jsonpath:
+ expression: "$.sObjectId"
- setHeader:
name: CamelSalesforceSObjectName
- jsonpath: "$.sObjectName"
+ expression:
+ jsonpath:
+ expression: "$.sObjectName"
- transform:
- jsonpath: "$.payload"
+ expression:
+ jsonpath:
+ expression: "$.payload"
- marshal:
json: {}
- to:
@@ -107,6 +113,6 @@ spec:
parameters:
rawPayload: "true"
- removeHeader:
- name: sObjectId
+ name: CamelSalesforceSObjectId
- removeHeader:
- name: sObjectName
+ name: CamelSalesforceSObjectName
diff --git
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml
index 04ab832e0..7ced1d1df 100644
---
a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml
+++
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.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-pipe.yaml
b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml
index dbc4f17c9..933fdac43 100644
--- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml
+++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml
@@ -35,8 +35,8 @@ spec:
properties:
topicFormat: $[topic]_$[timestamp]
timestampFormat: YYYY-MM-dd
- timestampHeaderName: kafka.TIMESTAMP
- topicHeaderName: kafka.TOPIC
+ timestampHeaderName: timestamp
+ topicHeaderName: topic
- ref:
kind: Kamelet
apiVersion: camel.apache.org/v1
