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 fb7649e18 Regen for commit 2e19447069ea4c1593669e91186cae723ce31333
(#3037)
fb7649e18 is described below
commit fb7649e18c94418246ac63697a40f22079d63f20
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Sep 16 11:28:13 2026 +0200
Regen for commit 2e19447069ea4c1593669e91186cae723ce31333 (#3037)
Signed-off-by: GitHub <[email protected]>
Co-authored-by: oscerd <[email protected]>
---
...icurio-registry-not-secured-source.kamelet.yaml | 35 ++++++++++++++++++++++
...kafka-azure-schema-registry-source.kamelet.yaml | 35 ++++++++++++++++++++++
...ured-apicurio-registry-json-source.kamelet.yaml | 35 ++++++++++++++++++++++
...t-secured-apicurio-registry-source.kamelet.yaml | 35 ++++++++++++++++++++++
.../resources/kamelets/kafka-source.kamelet.yaml | 35 ++++++++++++++++++++++
5 files changed, 175 insertions(+)
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
index 44247ff0a..ddf44a23a 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
@@ -115,4 +115,39 @@ spec:
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
+ # Kafka record metadata, surfaced under names that are not Camel
+ # internals, so a downstream consumer does not have to depend on the
+ # CamelKafka* headers. Plain form plus a CloudEvents one, as
+ # infinispan-source and ftp-source do. The CamelKafka* headers are left
+ # in place, so existing consumers are unaffected.
+ - setHeader:
+ name: kafka-topic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: ce-kafkatopic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: kafka-key
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: ce-kafkakey
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: kafka-partition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: ce-kafkapartition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: kafka-offset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: ce-kafkaoffset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: kafka-timestamp
+ simple: "${header[CamelKafkaTimestamp]}"
+ - setHeader:
+ name: ce-kafkatimestamp
+ simple: "${header[CamelKafkaTimestamp]}"
- to: "kamelet:sink"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 8e8344560..900ee9216 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -150,4 +150,39 @@ spec:
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
+ # Kafka record metadata, surfaced under names that are not Camel
+ # internals, so a downstream consumer does not have to depend on the
+ # CamelKafka* headers. Plain form plus a CloudEvents one, as
+ # infinispan-source and ftp-source do. The CamelKafka* headers are left
+ # in place, so existing consumers are unaffected.
+ - setHeader:
+ name: kafka-topic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: ce-kafkatopic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: kafka-key
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: ce-kafkakey
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: kafka-partition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: ce-kafkapartition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: kafka-offset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: ce-kafkaoffset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: kafka-timestamp
+ simple: "${header[CamelKafkaTimestamp]}"
+ - setHeader:
+ name: ce-kafkatimestamp
+ simple: "${header[CamelKafkaTimestamp]}"
- to: "kamelet:sink"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
index 4c5a6e718..fa95219f4 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
@@ -158,4 +158,39 @@ spec:
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
+ # Kafka record metadata, surfaced under names that are not Camel
+ # internals, so a downstream consumer does not have to depend on the
+ # CamelKafka* headers. Plain form plus a CloudEvents one, as
+ # infinispan-source and ftp-source do. The CamelKafka* headers are left
+ # in place, so existing consumers are unaffected.
+ - setHeader:
+ name: kafka-topic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: ce-kafkatopic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: kafka-key
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: ce-kafkakey
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: kafka-partition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: ce-kafkapartition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: kafka-offset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: ce-kafkaoffset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: kafka-timestamp
+ simple: "${header[CamelKafkaTimestamp]}"
+ - setHeader:
+ name: ce-kafkatimestamp
+ simple: "${header[CamelKafkaTimestamp]}"
- to: "kamelet:sink"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
index 4eeb0c89d..75ca2e508 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
@@ -167,4 +167,39 @@ spec:
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
+ # Kafka record metadata, surfaced under names that are not Camel
+ # internals, so a downstream consumer does not have to depend on the
+ # CamelKafka* headers. Plain form plus a CloudEvents one, as
+ # infinispan-source and ftp-source do. The CamelKafka* headers are left
+ # in place, so existing consumers are unaffected.
+ - setHeader:
+ name: kafka-topic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: ce-kafkatopic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: kafka-key
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: ce-kafkakey
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: kafka-partition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: ce-kafkapartition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: kafka-offset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: ce-kafkaoffset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: kafka-timestamp
+ simple: "${header[CamelKafkaTimestamp]}"
+ - setHeader:
+ name: ce-kafkatimestamp
+ simple: "${header[CamelKafkaTimestamp]}"
- to: "kamelet:sink"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
index 234f9469c..1b638a852 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
@@ -181,4 +181,39 @@ spec:
steps:
- process:
ref: "{{kafkaHeaderDeserializer}}"
+ # Kafka record metadata, surfaced under names that are not Camel
+ # internals, so a downstream consumer does not have to depend on the
+ # CamelKafka* headers. Plain form plus a CloudEvents one, as
+ # infinispan-source and ftp-source do. The CamelKafka* headers are left
+ # in place, so existing consumers are unaffected.
+ - setHeader:
+ name: kafka-topic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: ce-kafkatopic
+ simple: "${header[CamelKafkaTopic]}"
+ - setHeader:
+ name: kafka-key
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: ce-kafkakey
+ simple: "${header[CamelKafkaKey]}"
+ - setHeader:
+ name: kafka-partition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: ce-kafkapartition
+ simple: "${header[CamelKafkaPartition]}"
+ - setHeader:
+ name: kafka-offset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: ce-kafkaoffset
+ simple: "${header[CamelKafkaOffset]}"
+ - setHeader:
+ name: kafka-timestamp
+ simple: "${header[CamelKafkaTimestamp]}"
+ - setHeader:
+ name: ce-kafkatimestamp
+ simple: "${header[CamelKafkaTimestamp]}"
- to: "kamelet:sink"
