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 ab34eb479 Regen for commit ae02160d87e163a427a29f27d155224f26d733f9
(#3031)
ab34eb479 is described below
commit ab34eb47905f3d05e3bbfe741487012031f672ae
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Sep 14 18:07:36 2026 +0200
Regen for commit ae02160d87e163a427a29f27d155224f26d733f9 (#3031)
Signed-off-by: GitHub <[email protected]>
Co-authored-by: oscerd <[email protected]>
---
.../kamelets/ceph-event-based-source.kamelet.yaml | 29 ++++++++++++++++++++++
1 file changed, 29 insertions(+)
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/ceph-event-based-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/ceph-event-based-source.kamelet.yaml
index 3db5f2067..f4e65acd7 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/ceph-event-based-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/ceph-event-based-source.kamelet.yaml
@@ -122,6 +122,35 @@ spec:
saslUsername: "{{?saslUsername}}"
saslPassword: "{{?saslPassword}}"
steps:
+ # Ceph extension fields, surfaced as headers so a consumer does not
have
+ # to re-parse the body for them. Named the way the catalog names source
+ # output headers -- a plain form plus a CloudEvents one, as
+ # infinispan-source and ftp-source do. s3.bucket.id is deliberately not
+ # surfaced: it is an internal Ceph id useful only for debugging.
+ - setHeader:
+ name: ceph-event-id
+ jsonpath: $.Records[0].eventId
+ - setHeader:
+ name: ce-cepheventid
+ simple: "${header[ceph-event-id]}"
+ - setHeader:
+ name: ceph-opaque-data
+ jsonpath: $.Records[0].opaqueData
+ - setHeader:
+ name: ce-cephopaquedata
+ simple: "${header[ceph-opaque-data]}"
+ - setHeader:
+ name: ceph-object-metadata
+ jsonpath: $.Records[0].s3.object.metadata
+ - setHeader:
+ name: ce-cephobjectmetadata
+ simple: "${header[ceph-object-metadata]}"
+ - setHeader:
+ name: ceph-object-tags
+ jsonpath: $.Records[0].s3.object.tags
+ - setHeader:
+ name: ce-cephobjecttags
+ simple: "${header[ceph-object-tags]}"
# Ceph emits the classic S3 notification envelope -- a Records array --
# not the EventBridge shape that aws-s3-event-based-source parses, so
the
# paths below are Records based on purpose.