This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch camel-4.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.18.x by this push:
new 0292c4f21f00 Fix camel export failure with cassandra-sink kamelet when
extraTypeCodecs is not set
0292c4f21f00 is described below
commit 0292c4f21f0080038216c8424f26d056f48d92cd
Author: Salvatore Mongiardo <[email protected]>
AuthorDate: Thu Feb 26 14:28:10 2026 +0100
Fix camel export failure with cassandra-sink kamelet when extraTypeCodecs
is not set
During camel export, unset optional kamelet properties are replaced with
the @@CamelMagicValue@@ placeholder by ExportPropertiesParser. The
CassandraEndpoint.createSessionBuilder() method passes this value
directly to CassandraExtraCodecs.valueOf(), causing an
IllegalArgumentException. Skip processing extraTypeCodecs when it
contains the magic placeholder value.
---
.../java/org/apache/camel/component/cassandra/CassandraEndpoint.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
index ba94a025e5ab..c043235e9a9a 100644
---
a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
+++
b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
@@ -41,6 +41,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.apache.camel.support.CamelContextHelper;
import org.apache.camel.support.ScheduledPollEndpoint;
+import org.apache.camel.support.component.PropertyConfigurerSupport;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.utils.cassandra.CassandraExtraCodecs;
import org.apache.camel.utils.cassandra.CassandraSessionHolder;
@@ -191,7 +192,7 @@ public class CassandraEndpoint extends
ScheduledPollEndpoint implements Endpoint
sessionBuilder.withClassLoader(classLoader);
}
- if (extraTypeCodecs != null) {
+ if (extraTypeCodecs != null &&
!PropertyConfigurerSupport.MAGIC_VALUE.equals(extraTypeCodecs)) {
String[] c = extraTypeCodecs.split(",");
if (LOG.isDebugEnabled()) {