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

Reply via email to