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 41b60fdba Fix #3038: kafka-sink should accept kafka-key and
ce-kafkakey (#3039)
41b60fdba is described below
commit 41b60fdbaa2f1bb9ec24e0331f6f3054fabc64ac
Author: Abhirama <[email protected]>
AuthorDate: Thu Sep 17 13:26:53 2026 +0530
Fix #3038: kafka-sink should accept kafka-key and ce-kafkakey (#3039)
---
docs/modules/ROOT/partials/kafka-sink-description.adoc | 2 +-
kamelets/kafka-sink.kamelet.yaml | 10 ++++++++++
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/docs/modules/ROOT/partials/kafka-sink-description.adoc
b/docs/modules/ROOT/partials/kafka-sink-description.adoc
index dcda3ef30..75babb9a8 100644
--- a/docs/modules/ROOT/partials/kafka-sink-description.adoc
+++ b/docs/modules/ROOT/partials/kafka-sink-description.adoc
@@ -4,7 +4,7 @@
The Kamelet is able to understand the following headers to be set:
-- `key` / `ce-key`: as message key
+- `key` / `kafka-key` / `ce-key` / `ce-kafkakey`: as message key
- `partition-key` / `ce-partitionkey`: as message partition key
Both headers are optional.
diff --git a/kamelets/kafka-sink.kamelet.yaml b/kamelets/kafka-sink.kamelet.yaml
index 75eb8cb74..f2ca191d0 100644
--- a/kamelets/kafka-sink.kamelet.yaml
+++ b/kamelets/kafka-sink.kamelet.yaml
@@ -126,11 +126,21 @@ spec:
- setHeader:
name: CamelKafkaKey
simple: "${header[key]}"
+ - simple: "${header[kafka-key]}"
+ steps:
+ - setHeader:
+ name: CamelKafkaKey
+ simple: "${header[kafka-key]}"
- simple: "${header[ce-key]}"
steps:
- setHeader:
name: CamelKafkaKey
simple: "${header[ce-key]}"
+ - simple: "${header[ce-kafkakey]}"
+ steps:
+ - setHeader:
+ name: CamelKafkaKey
+ simple: "${header[ce-kafkakey]}"
- choice:
when:
- simple: "${header[partition-key]}"
