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
The following commit(s) were added to refs/heads/main by this push:
new a636e488b Reflect changes from CAMEL-21843 in involved Kamelets -
Kafka Header Deserializer (#2420)
a636e488b is described below
commit a636e488b9671a7c4582624550620b6ea5e3b432
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Mar 14 12:19:22 2025 +0100
Reflect changes from CAMEL-21843 in involved Kamelets - Kafka Header
Deserializer (#2420)
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml | 2 +-
kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-not-secured-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-scram-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-ssl-source.kamelet.yaml | 2 +-
kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml | 2 +-
kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml | 2 +-
kamelets/kafka-not-secured-source.kamelet.yaml | 2 +-
kamelets/kafka-scram-source.kamelet.yaml | 2 +-
kamelets/kafka-source.kamelet.yaml | 2 +-
kamelets/kafka-ssl-source.kamelet.yaml | 2 +-
.../kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml | 2 +-
.../resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 2 +-
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 2 +-
.../kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml | 2 +-
.../kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 2 +-
.../main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-batch-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml | 2 +-
.../kafka-not-secured-apicurio-registry-json-source.kamelet.yaml | 2 +-
.../kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-scram-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml | 2 +-
30 files changed, 30 insertions(+), 30 deletions(-)
diff --git a/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
b/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
index 32f4a30b1..b3590970a 100644
--- a/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
@@ -113,7 +113,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 081d9d19c..352e73ce8 100644
--- a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -143,7 +143,7 @@ spec:
- name: defaultAzureCredential
type:
"#class:org.apache.camel.component.azure.schema.registry.DefaultAzureCredentialWrapper"
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index 7aa70e96f..7f42e364c 100644
--- a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -136,7 +136,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git a/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
b/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
index b61d0f85a..643a4e523 100644
--- a/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
@@ -177,7 +177,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index f62231d1c..f5d2de40a 100644
--- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -161,7 +161,7 @@ spec:
- name: defaultAzureCredential
type:
"#class:org.apache.camel.component.azure.schema.registry.DefaultAzureCredentialWrapper"
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git a/kamelets/kafka-batch-not-secured-source.kamelet.yaml
b/kamelets/kafka-batch-not-secured-source.kamelet.yaml
index f146dd7c4..9c1115e91 100644
--- a/kamelets/kafka-batch-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-not-secured-source.kamelet.yaml
@@ -117,7 +117,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git a/kamelets/kafka-batch-scram-source.kamelet.yaml
b/kamelets/kafka-batch-scram-source.kamelet.yaml
index 9827e9617..0e5d59f35 100644
--- a/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -148,7 +148,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git a/kamelets/kafka-batch-source.kamelet.yaml
b/kamelets/kafka-batch-source.kamelet.yaml
index 44c62a9b0..ca9fb1469 100644
--- a/kamelets/kafka-batch-source.kamelet.yaml
+++ b/kamelets/kafka-batch-source.kamelet.yaml
@@ -148,7 +148,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git a/kamelets/kafka-batch-ssl-source.kamelet.yaml
b/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 8a17e2495..8ea5327d8 100644
--- a/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -202,7 +202,7 @@ spec:
topicIsPattern: "{{topicIsPattern}}"
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
b/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
index ff3c29f35..70b169a06 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
@@ -154,7 +154,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git a/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
b/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
index f1a0dc1e9..1798636f3 100644
--- a/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
@@ -159,7 +159,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml
b/kamelets/kafka-not-secured-source.kamelet.yaml
index 4ec5a0777..b2f623c8c 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -99,7 +99,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git a/kamelets/kafka-scram-source.kamelet.yaml
b/kamelets/kafka-scram-source.kamelet.yaml
index 5b3d14daf..a2796bd98 100644
--- a/kamelets/kafka-scram-source.kamelet.yaml
+++ b/kamelets/kafka-scram-source.kamelet.yaml
@@ -130,7 +130,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git a/kamelets/kafka-source.kamelet.yaml
b/kamelets/kafka-source.kamelet.yaml
index e15dd029d..fbde9cd99 100644
--- a/kamelets/kafka-source.kamelet.yaml
+++ b/kamelets/kafka-source.kamelet.yaml
@@ -130,7 +130,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git a/kamelets/kafka-ssl-source.kamelet.yaml
b/kamelets/kafka-ssl-source.kamelet.yaml
index d5b7927ba..09abc9431 100644
--- a/kamelets/kafka-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-ssl-source.kamelet.yaml
@@ -186,7 +186,7 @@ spec:
topicIsPattern: '{{topicIsPattern}}'
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
index 32f4a30b1..b3590970a 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml
@@ -113,7 +113,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 081d9d19c..352e73ce8 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -143,7 +143,7 @@ spec:
- name: defaultAzureCredential
type:
"#class:org.apache.camel.component.azure.schema.registry.DefaultAzureCredentialWrapper"
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index 7aa70e96f..7f42e364c 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -136,7 +136,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
index b61d0f85a..643a4e523 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml
@@ -177,7 +177,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index f62231d1c..f5d2de40a 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -161,7 +161,7 @@ spec:
- name: defaultAzureCredential
type:
"#class:org.apache.camel.component.azure.schema.registry.DefaultAzureCredentialWrapper"
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
index f146dd7c4..9c1115e91 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
@@ -117,7 +117,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
index 9827e9617..0e5d59f35 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -148,7 +148,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
index 44c62a9b0..ca9fb1469 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
@@ -148,7 +148,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
- name: manualCommitFactory
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 8a17e2495..8ea5327d8 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -202,7 +202,7 @@ spec:
topicIsPattern: "{{topicIsPattern}}"
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
index ff3c29f35..70b169a06 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml
@@ -154,7 +154,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
index f1a0dc1e9..1798636f3 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml
@@ -159,7 +159,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
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 4ec5a0777..b2f623c8c 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
@@ -99,7 +99,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
index 5b3d14daf..a2796bd98 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml
@@ -130,7 +130,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
index e15dd029d..fbde9cd99 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
@@ -130,7 +130,7 @@ spec:
template:
beans:
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
index d5b7927ba..09abc9431 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml
@@ -186,7 +186,7 @@ spec:
topicIsPattern: '{{topicIsPattern}}'
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
- name: kafkaHeaderDeserializer
- type:
"#class:org.apache.camel.component.kamelet.utils.serialization.kafka.KafkaHeaderDeserializer"
+ type: "#class:org.apache.camel.component.kafka.KafkaHeaderDeserializer"
properties:
enabled: '{{deserializeHeaders}}'
from:
