Apache Cassandra 4.0.11触发器执行时CQLSession初始化报错：cluster_name已占用

java.lang.IllegalArgumentException: 'cluster_name' is already in use的本质是Netty AttributeKey命名冲突：

• Cassandra服务端的Netty环境已注册名为cluster_name的AttributeKey
• 触发器中嵌入的DataStax Java Driver初始化时，尝试重复创建同名AttributeKey，但Netty的ConstantPool不允许相同名称的常量重复注册
• 触发器运行在Cassandra的JVM进程内，Driver与Cassandra共享同一Netty上下文，直接触发冲突

方案1：复用Cassandra内部Session（推荐） #

无需自行初始化CQLSession，直接调用Cassandra进程内部的Session实例执行操作，彻底规避Driver初始化带来的冲突：

import org.apache.cassandra.db.Session;
import org.apache.cassandra.service.ClientState;

// 获取Cassandra内部会话
Session internalSession = ClientState.getInternalClientState().getSession();
// 执行CQL语句
internalSession.execute("INSERT INTO orders.your_table (...) VALUES (...)");

方案2：自定义Driver的Netty AttributeKey前缀 #

若必须使用独立的DataStax Driver实例，可通过配置修改Driver使用的AttributeKey前缀，避免与Cassandra内部命名冲突：
在Driver的HOCON配置中添加以下高级参数：

datastax-java-driver {
    advanced {
        netty {
            attribute-key-prefix = "custom-driver-"
        }
    }
    // 保留原有其他配置
    basic {
        config-reload-interval = 0
        session-name = "cassandra"
        session-keyspace = "orders"
        contact-points = [ "127.0.0.1:9042" ]
        load-balancing-policy.local-datacenter = "dc3"
        request {
            consistency = LOCAL_QUORUM
            serial-consistency = LOCAL_SERIAL
            timeout = 6 seconds
        }
    }
    advanced {
        ssl-engine-factory {
            class = DefaultSslEngineFactory
            hostname-validation = false
        }
    }
}

方案3：对齐Driver与Cassandra的Netty版本 #

Cassandra 4.0.11内置Netty版本为4.1.77.Final，确保你使用的DataStax Driver依赖的Netty版本与之一致，版本不匹配会增加冲突概率。调整依赖配置（如Maven/Gradle），强制Netty版本对齐。

内容的提问来源于stack exchange，提问作者Dencil