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()) {

Reply via email to