This is an automated email from the ASF dual-hosted git repository.
oscerd 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 21d8d882d Regen for commit 999a8d781867c67610e2e4307a4cb31eb3455449
(#2998)
21d8d882d is described below
commit 21d8d882d1eba4a708c6f439c73500895ab465db
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Sep 3 18:38:50 2026 +0200
Regen for commit 999a8d781867c67610e2e4307a4cb31eb3455449 (#2998)
Signed-off-by: GitHub <[email protected]>
Co-authored-by: oscerd <[email protected]>
---
docs/modules/ROOT/nav.adoc | 4 ++--
kamelets/jms-apache-artemis-sink.kamelet.yaml | 2 +-
kamelets/jms-apache-artemis-source.kamelet.yaml | 2 +-
.../jms-pooled-apache-artemis-sink.kamelet.yaml | 2 +-
.../jms-pooled-apache-artemis-source.kamelet.yaml | 2 +-
.../resources/kamelets/aws-ddb-sink.kamelet.yaml | 7 +++++-
.../kamelets/jms-apache-artemis-sink.kamelet.yaml | 2 +-
.../jms-apache-artemis-source.kamelet.yaml | 2 +-
.../jms-pooled-apache-artemis-sink.kamelet.yaml | 2 +-
.../jms-pooled-apache-artemis-source.kamelet.yaml | 2 +-
...apicurio-registry-not-secured-sink.kamelet.yaml | 7 ++++--
...icurio-registry-not-secured-source.kamelet.yaml | 7 ++++--
...fka-batch-apicurio-registry-source.kamelet.yaml | 7 ++++--
...not-secured-apicurio-registry-sink.kamelet.yaml | 7 ++++--
...t-secured-apicurio-registry-source.kamelet.yaml | 7 ++++--
.../kamelets/replace-field-action.kamelet.yaml | 13 +++++++----
.../kamelets/spring-rabbitmq-sink.kamelet.yaml | 25 ++++++++++++++++++++++
17 files changed, 75 insertions(+), 25 deletions(-)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index a3d0047e7..a2a7eb6ba 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -221,9 +221,9 @@
* xref:simple-filter-action.adoc[]
* xref:slack-sink.adoc[]
* xref:slack-source.adoc[]
-* xref:snmp-source.adoc[]
-* xref:smpp-source.adoc[]
* xref:smpp-sink.adoc[]
+* xref:smpp-source.adoc[]
+* xref:snmp-source.adoc[]
* xref:snowflake-sink.adoc[]
* xref:snowflake-source.adoc[]
* xref:solr-sink.adoc[]
diff --git a/kamelets/jms-apache-artemis-sink.kamelet.yaml
b/kamelets/jms-apache-artemis-sink.kamelet.yaml
index 364ef7d5c..5005105d8 100644
--- a/kamelets/jms-apache-artemis-sink.kamelet.yaml
+++ b/kamelets/jms-apache-artemis-sink.kamelet.yaml
@@ -55,7 +55,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
template:
beans:
- name: connectionFactoryBean
diff --git a/kamelets/jms-apache-artemis-source.kamelet.yaml
b/kamelets/jms-apache-artemis-source.kamelet.yaml
index 937250289..540428db6 100644
--- a/kamelets/jms-apache-artemis-source.kamelet.yaml
+++ b/kamelets/jms-apache-artemis-source.kamelet.yaml
@@ -54,7 +54,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
template:
beans:
- name: connectionFactoryBean
diff --git a/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
b/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
index 136e427ea..141a48998 100644
--- a/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
+++ b/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
@@ -83,7 +83,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
- "mvn:org.messaginghub:pooled-jms:3.2.4"
template:
beans:
diff --git a/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
b/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
index d59034c05..aa86fc90d 100644
--- a/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
+++ b/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
@@ -82,7 +82,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
- "mvn:org.messaginghub:pooled-jms:3.2.4"
template:
beans:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
index e978ccee1..5e1e611c3 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
@@ -103,8 +103,13 @@ spec:
type: boolean
default: false
dataTypes:
+ # No 'default:' here on purpose. Declaring a default input type makes Camel
+ # apply the aws2-ddb:application-json transformation at the kamelet:source
+ # boundary, before any step below runs -- so the operation set by this
+ # template was never visible to it and every message was transformed as
+ # PutItem. The transformDataType step below applies the same type after the
+ # operation is set. See #2941.
in:
- default: json
types:
json:
format: "aws2-ddb:application-json"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml
index 364ef7d5c..5005105d8 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml
@@ -55,7 +55,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
template:
beans:
- name: connectionFactoryBean
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml
index 937250289..540428db6 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml
@@ -54,7 +54,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
template:
beans:
- name: connectionFactoryBean
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
index 136e427ea..141a48998 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
@@ -83,7 +83,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
- "mvn:org.messaginghub:pooled-jms:3.2.4"
template:
beans:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
index d59034c05..aa86fc90d 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
@@ -82,7 +82,7 @@ spec:
dependencies:
- "camel:jms"
- "camel:kamelet"
- - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.55.0"
+ - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.56.0"
- "mvn:org.messaginghub:pooled-jms:3.2.4"
template:
beans:
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
index 3cef7d02d..95285571e 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml
@@ -56,9 +56,12 @@ spec:
type: string
avroDatumProvider:
title: Avro Datum Provider
- description: How to write data with Avro.
+ description: How to write data with Avro. Defaults to Apicurio's own
DefaultAvroDatumProvider,
+ which handles GenericRecord and generated SpecificRecord classes. Set
+ io.apicurio.registry.serde.avro.ReflectAvroDatumProvider to map
arbitrary POJOs onto Avro
+ by reflection instead.
type: string
- default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
+ default: "io.apicurio.registry.serde.avro.DefaultAvroDatumProvider"
dependencies:
- "camel:core"
- "camel:kamelet"
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 0211c4575..801d1df3a 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
@@ -86,9 +86,12 @@ spec:
type: string
avroDatumProvider:
title: Avro Datum Provider
- description: How to read data with Avro.
+ description: How to read data with Avro. Defaults to Apicurio's own
DefaultAvroDatumProvider,
+ which handles GenericRecord and generated SpecificRecord classes. Set
+ io.apicurio.registry.serde.avro.ReflectAvroDatumProvider to map Avro
onto arbitrary POJOs
+ by reflection instead..
type: string
- default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
+ default: "io.apicurio.registry.serde.avro.DefaultAvroDatumProvider"
batchSize:
title: Batch Dimension
description: The maximum number of records returned in a single call
to poll().
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 26c782b9a..e326f6445 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
@@ -92,9 +92,12 @@ spec:
type: string
avroDatumProvider:
title: Avro Datum Provider
- description: How to read data with Avro
+ description: How to read data with Avro. Defaults to Apicurio's own
DefaultAvroDatumProvider,
+ which handles GenericRecord and generated SpecificRecord classes. Set
+ io.apicurio.registry.serde.avro.ReflectAvroDatumProvider to map Avro
onto arbitrary POJOs
+ by reflection instead.
type: string
- default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
+ default: "io.apicurio.registry.serde.avro.DefaultAvroDatumProvider"
batchSize:
title: Batch Dimension
description: The maximum number of records returned in a single call
to poll()
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
index c2b9d0cb9..31ccd272a 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml
@@ -62,9 +62,12 @@ spec:
type: string
avroDatumProvider:
title: Avro Datum Provider
- description: How to write data with Avro
+ description: How to write data with Avro. Defaults to Apicurio's own
DefaultAvroDatumProvider,
+ which handles GenericRecord and generated SpecificRecord classes. Set
+ io.apicurio.registry.serde.avro.ReflectAvroDatumProvider to map
arbitrary POJOs onto Avro
+ by reflection instead.
type: string
- default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
+ default: "io.apicurio.registry.serde.avro.DefaultAvroDatumProvider"
apicurioAuthServiceUrl:
title: Apicurio Registry Auth Service URL
description: The URL for Keycloak instance securing the Apicurio
Registry
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 3fd442c23..4eeb0c89d 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
@@ -92,9 +92,12 @@ spec:
type: string
avroDatumProvider:
title: Avro Datum Provider
- description: How to read data with Avro
+ description: How to read data with Avro. Defaults to Apicurio's own
DefaultAvroDatumProvider,
+ which handles GenericRecord and generated SpecificRecord classes. Set
+ io.apicurio.registry.serde.avro.ReflectAvroDatumProvider to map Avro
onto arbitrary POJOs
+ by reflection instead.
type: string
- default: "io.apicurio.registry.serde.avro.ReflectAvroDatumProvider"
+ default: "io.apicurio.registry.serde.avro.DefaultAvroDatumProvider"
apicurioAuthServiceUrl:
title: Apicurio Registry Auth Service URL
description: The URL for Keycloak instance securing the Apicurio
Registry
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/replace-field-action.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/replace-field-action.kamelet.yaml
index 33c5208a9..ee03ff120 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/replace-field-action.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/replace-field-action.kamelet.yaml
@@ -30,23 +30,28 @@ metadata:
spec:
definition:
title: "Replace Field Action"
- description: Replace field with a different key in the message in transit.
+ description: |-
+ Replace field with a different key in the message in transit.
+
+ Only top level fields are considered. Fields nested inside an object are
passed through
+ untouched, so a rename that names a nested field has no effect.
required:
- renames
properties:
enabled:
title: Enabled
- description: Comma separated list of fields to be enabled
+ description: Comma separated list of top level fields to be enabled
type: string
default: "all"
disabled:
title: Disabled
- description: Comma separated list of fields to be disabled
+ description: Comma separated list of top level fields to be disabled
type: string
default: "none"
renames:
title: Renames
- description: Comma separated list of field with new value to be renamed
+ description: Comma separated list of field with new value to be
renamed. Only top level
+ fields are renamed; naming a field nested inside an object has no
effect.
type: string
example: "foo:bar,c1:c2"
type: object
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
index 5ed6e5675..e671dea23 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -77,6 +77,28 @@ spec:
description: Specifies whether the producer should auto declare
binding between exchange, queue and routing key when starting
type: boolean
default: false
+ publisherConfirmType:
+ title: Publisher Confirm Type
+ description: The publisher confirm mode of the underlying connection
factory. Must be SIMPLE or
+ CORRELATED for the confirm option below to have anything to wait on.
NONE, the default, leaves
+ publisher confirms switched off.
+ type: string
+ default: "NONE"
+ enum: ["NONE", "SIMPLE", "CORRELATED"]
+ confirm:
+ title: Confirm
+ description: Controls whether to wait for publisher confirms. auto
lets Camel detect whether the
+ connection factory is configured for confirms, enabled always waits,
disabled never waits.
+ Requires publisherConfirmType to be SIMPLE or CORRELATED.
+ type: string
+ default: "auto"
+ enum: ["auto", "enabled", "disabled"]
+ confirmTimeout:
+ title: Confirm Timeout
+ description: How long in milliseconds to wait for a sent message to be
confirmed by RabbitMQ when
+ doing send-only (InOnly) messaging. A negative value waits
indefinitely.
+ type: string
+ default: "5000"
vhost:
title: Virtual Host
description: The virtual host
@@ -100,6 +122,7 @@ spec:
password: '{{?password}}'
uri: '{{protocol}}://{{host}}:{{port}}'
virtualHost: "{{vhost}}"
+ publisherConfirmType: "{{publisherConfirmType}}"
from:
uri: "kamelet:source"
steps:
@@ -110,3 +133,5 @@ spec:
routingKey: "{{?routingKey}}"
queues: "{{?queues}}"
autoDeclareProducer: "{{autoDeclareProducer}}"
+ confirm: "{{confirm}}"
+ confirmTimeout: "{{confirmTimeout}}"
