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: {}