This is an automated email from the ASF dual-hosted git repository.

oscerd 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 5bac6a92e Fix Kafka SMT kamelets for CAMEL-23584 header rename (#2876)
5bac6a92e is described below

commit 5bac6a92eb033e48ae25103213de95857e7516b3
Author: Marco Carletti <[email protected]>
AuthorDate: Wed Jun 24 12:09:23 2026 +0200

    Fix Kafka SMT kamelets for CAMEL-23584 header rename (#2876)
    
    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 a5db4810b..2b4d44fde 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"
     type: object
   dependencies:
   - "camel:kamelet"
diff --git a/kamelets/topic-name-matches-filter-action.kamelet.yaml 
b/kamelets/topic-name-matches-filter-action.kamelet.yaml
index 9a4067967..417726db1 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 a5db4810b..2b4d44fde 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"
     type: object
   dependencies:
   - "camel:kamelet"
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 9a4067967..417726db1 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: {}

Reply via email to