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:45 UTC
[camel-kamelets] branch 3.20.x-mq-kafka created (now c70ef48a)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 3.20.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at c70ef48a MQ sink does not map headers from Kafka source
This branch includes the following new commits:
new 206d3998 MQ sink does not map headers from Kafka source
new bf449ca0 MQ sink does not map headers from Kafka source
new 545d3ae2 MQ sink does not map headers from Kafka source
new c70ef48a 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] 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.20.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit bf449ca0409cd466e7a8bb10420a147040d68274
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 bc58241e..adada8c5 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] 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.20.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 545d3ae23f6965b02f7975b104e6ed1c8cc7b955
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:25:14 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 adada8c5..547f66b4 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.20.2-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.20.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit c70ef48a37fa1641bf8ed21a2e610a0f0e854478
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:26:16 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 2d93121a..547f66b4 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.20.2-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.20.x-mq-kafka
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 206d3998e5f2014859a3182ee428a486430120ac
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 2d93121a..bc58241e 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"