[camel-kamelets] 04/04: MQ sink does not map headers from Kafka source

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit fb31175edff394b4cac7b2b1dfa09ed155c9f135
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Mar 1 13:35:14 2023 +0100

    MQ sink does not map headers from Kafka source
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../kamelets/kafka-not-secured-source.kamelet.yaml    | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git 
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
index 5d776f7e..440ddbd7 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -86,10 +86,25 @@ spec:
         x-descriptors:
         - urn:keda:metadata:consumerGroup
         - urn:keda:required
+      deserializeHeaders:
+        title: Automatically Deserialize Headers
+        description: When enabled the Kamelet source will deserialize all 
message headers to String representation.
+        type: boolean
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+        default: false
   dependencies:
+    - "github:apache.camel-kamelets:camel-kamelets-utils:4.0.0-SNAPSHOT"
     - "camel:kafka"
+    - "camel:core"
     - "camel:kamelet"
   template:
+    beans:
+      - name: kafkaHeaderDeserializer
+        type: 
"#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"
+        property:
+          - key: enabled
+            value: '{{deserializeHeaders}}'
     from:
       uri: "kafka:{{topic}}"
       parameters:
@@ -100,4 +115,6 @@ spec:
         autoOffsetReset: "{{autoOffsetReset}}"
         groupId: "{{?consumerGroup}}"
       steps:
-      - to: "kamelet:sink"
+        - process:
+            ref: "{{kafkaHeaderDeserializer}}"
+        - to: "kamelet:sink"