This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch camel-4.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.14.x by this push:
new 57f6b772bb83 Fix camel export failure with cassandra-sink kamelet when
extraTypeCodecs is not set
57f6b772bb83 is described below
commit 57f6b772bb83027691e30c390b2c80c90e2268f5
Author: Salvatore Mongiardo <[email protected]>
AuthorDate: Thu Feb 26 14:27:44 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()) {