You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2023/03/01 12:46:24 UTC
[camel-kamelets] 04/06: MQ sink does not map headers from Kafka source
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 3.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit b501cd8b36b267a6e0cf2d93947527d5e2fb934d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:24:01 2023 +0100
MQ sink does not map headers from Kafka source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kamelets/kafka-not-secured-source.kamelet.yaml | 18 +++++++++++++++++-
1 file changed, 17 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 a1cc3781..420a6408 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,24 @@ 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:3.21.0-SNAPSHOT"
- "camel:kafka"
- "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 +114,6 @@ spec:
autoOffsetReset: "{{autoOffsetReset}}"
groupId: "{{?consumerGroup}}"
steps:
- - to: "kamelet:sink"
+ - process:
+ ref: "{{kafkaHeaderDeserializer}}"
+ - to: "kamelet:sink"