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.

Reply via email to