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:31:36 UTC
[camel-kamelets] branch 3.x-mq-kafka created (now 412874d8)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 3.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 412874d8 MQ sink does not map headers from Kafka source
This branch includes the following new commits:
new ac587aa4 MQ sink does not map headers from Kafka source
new c315d865 MQ sink does not map headers from Kafka source
new 65b1f844 MQ sink does not map headers from Kafka source
new 412874d8 MQ sink does not map headers from Kafka source
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kamelets] 03/04: MQ sink does not map headers from Kafka source
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 3.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 65b1f844f83300d2718ce6ec3e9131775592d92e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:23:22 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 | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index efecc8e6..420a6408 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -94,7 +94,7 @@ spec:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
- - "github:apache.camel-kamelets:camel-kamelets-utils:4.0.0-SNAPSHOT"
+ - "github:apache.camel-kamelets:camel-kamelets-utils:3.21.0-SNAPSHOT"
- "camel:kafka"
- "camel:kamelet"
template:
[camel-kamelets] 02/04: MQ sink does not map headers from Kafka source
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 3.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit c315d865eef7072c71f713d9c3035bb606020b4d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:21:33 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 | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index eae7aec9..efecc8e6 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -94,7 +94,7 @@ spec:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
- - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.0.0-M1"
+ - "github:apache.camel-kamelets:camel-kamelets-utils:4.0.0-SNAPSHOT"
- "camel:kafka"
- "camel:kamelet"
template:
[camel-kamelets] 04/04: MQ sink does not map headers from Kafka source
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 3.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 412874d89ccebb959767d642159607828c855249
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"
[camel-kamelets] 01/04: MQ sink does not map headers from Kafka source
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 3.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ac587aa4647292baad729e4c1a2b265b8159c355
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:15:48 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/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index a1cc3781..eae7aec9 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/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:
+ - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.0.0-M1"
- "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"