(camel-kamelets) branch main updated: Fix Kafka SMT kamelets for CAMEL-23584 header rename (#2875)

[acosentino]

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 49d30bc75 Fix Kafka SMT kamelets for CAMEL-23584 header rename (#2875)
49d30bc75 is described below

commit 49d30bc75663dd8baf3e2988d6ca6dd56f0c3158
Author: Marco Carletti <mcarl...@ibm.com>
AuthorDate: Wed Jun 24 12:09:42 2026 +0200

    Fix Kafka SMT kamelets for CAMEL-23584 header rename (#2875)
    
    CAMEL-23584 renamed all camel-kafka Exchange header constants from
    kafka.* to CamelKafka* prefix. Two kamelet YAML definitions still
    used the old names, causing silent failures:
    
    - topic-name-matches-filter-action: ${header[kafka.TOPIC]} → 
${header[CamelKafkaTopic]}
    - timestamp-router-action: timestampHeaderName default kafka.TIMESTAMP → 
CamelKafkaTimestamp
---
 kamelets/timestamp-router-action.kamelet.yaml                           | 2 +-
 kamelets/topic-name-matches-filter-action.kamelet.yaml                  | 2 +-
 .../src/main/resources/kamelets/timestamp-router-action.kamelet.yaml    | 2 +-
 .../resources/kamelets/topic-name-matches-filter-action.kamelet.yaml    | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/kamelets/timestamp-router-action.kamelet.yaml 
b/kamelets/timestamp-router-action.kamelet.yaml
index cc01d8566..c287e4528 100644
--- a/kamelets/timestamp-router-action.kamelet.yaml
+++ b/kamelets/timestamp-router-action.kamelet.yaml
@@ -46,7 +46,7 @@ spec:
         title: Timestamp Header Name
         description: The name of the header containing a timestamp
         type: string
-        default: "kafka.TIMESTAMP"
+        default: "CamelKafkaTimestamp"
       topicHeaderName:
         title: Topic Header Name
         description: The name of the header containing the topic name. When 
not set, the default Kafka topic header (CamelKafkaTopic) is used.
diff --git a/kamelets/topic-name-matches-filter-action.kamelet.yaml 
b/kamelets/topic-name-matches-filter-action.kamelet.yaml
index 242d53396..5a0794231 100644
--- a/kamelets/topic-name-matches-filter-action.kamelet.yaml
+++ b/kamelets/topic-name-matches-filter-action.kamelet.yaml
@@ -47,6 +47,6 @@ spec:
       uri: kamelet:source
       steps:
       - filter:
-          simple: "${header[kafka.TOPIC]} !regex '{{regex}}'"
+          simple: "${header[CamelKafkaTopic]} !regex '{{regex}}'"
           steps:
             - stop: {}
diff --git 
a/library/camel-kamelets/src/main/resources/kamelets/timestamp-router-action.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/timestamp-router-action.kamelet.yaml
index cc01d8566..c287e4528 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/timestamp-router-action.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/timestamp-router-action.kamelet.yaml
@@ -46,7 +46,7 @@ spec:
         title: Timestamp Header Name
         description: The name of the header containing a timestamp
         type: string
-        default: "kafka.TIMESTAMP"
+        default: "CamelKafkaTimestamp"
       topicHeaderName:
         title: Topic Header Name
         description: The name of the header containing the topic name. When 
not set, the default Kafka topic header (CamelKafkaTopic) is used.
diff --git 
a/library/camel-kamelets/src/main/resources/kamelets/topic-name-matches-filter-action.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/topic-name-matches-filter-action.kamelet.yaml
index 242d53396..5a0794231 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/topic-name-matches-filter-action.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/topic-name-matches-filter-action.kamelet.yaml
@@ -47,6 +47,6 @@ spec:
       uri: kamelet:source
       steps:
       - filter:
-          simple: "${header[kafka.TOPIC]} !regex '{{regex}}'"
+          simple: "${header[CamelKafkaTopic]} !regex '{{regex}}'"
           steps:
             - stop: {}