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] branch 3.20.x updated (e7899380 -> d2ef523f)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 3.20.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from e7899380 Restore required setting for chatId and made documentation clearer.
new 9a4fac1d MQ sink does not map headers from Kafka source
new e62511b8 MQ sink does not map headers from Kafka source
new 48f320a5 MQ sink does not map headers from Kafka source
new abc3ef58 MQ sink does not map headers from Kafka source
new a04df07c MQ sink does not map headers from Kafka source
new d2ef523f MQ sink does not map headers from Kafka source
The 6 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.
Summary of changes:
kamelets/kafka-not-secured-source.kamelet.yaml | 19 ++++++++++++++++++-
.../kamelets/kafka-not-secured-source.kamelet.yaml | 19 ++++++++++++++++++-
2 files changed, 36 insertions(+), 2 deletions(-)
[camel-kamelets] 02/06: 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
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit e62511b868c4ce989e152ba1dfafef61adfb5938
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/06: 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
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 48f320a5026748d3a6fb4ff21e89efe3670643fc
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] 05/06: 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
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a04df07c977f3830f22e3f63e4b818f660179bfe
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:36:59 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 | 1 +
1 file changed, 1 insertion(+)
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index 547f66b4..85a5c9bd 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -96,6 +96,7 @@ spec:
dependencies:
- "github:apache.camel-kamelets:camel-kamelets-utils:3.20.2-SNAPSHOT"
- "camel:kafka"
+ - "camel:core"
- "camel:kamelet"
template:
beans:
[camel-kamelets] 01/06: 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
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 9a4fac1dd2ded680189cfb57ebd50241a88df247
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"
[camel-kamelets] 04/06: 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
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit abc3ef58ad56615d256ae3997a9929862a12cb57
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] 06/06: 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
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit d2ef523f2084f523fc2ef09d7e4cff9f6ac927a2
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 1 13:37:54 2023 +0100
MQ sink does not map headers from Kafka source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml | 1 +
1 file changed, 1 insertion(+)
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 547f66b4..85a5c9bd 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
@@ -96,6 +96,7 @@ spec:
dependencies:
- "github:apache.camel-kamelets:camel-kamelets-utils:3.20.2-SNAPSHOT"
- "camel:kafka"
+ - "camel:core"
- "camel:kamelet"
template:
beans: