apache-kafka - 如何在 cassandra 中添加外部 jar 以便在触发器中使用它们

Question

我创建了一个包含 Kafka 客户端库的影子 jar。但是这个 jar 放在 $cassaandra_home/conf/trigger 目录中时无法工作。有没有办法单独添加Kafka的外部jar，然后链接到主jar？

标签： apache-kafkajarcassandratriggers

Answer 1

它可能必须添加到 Cassandra 的CLASSPATH环境变量中。您可以通过在cassandra-env.sh文件中添加一行来引用其位置来做到这一点：

CLASSPATH="$CLASSPATH:$CASSANDRA_HOME/lib/cassandra-ldap-3.11.4.jar"

上面的行允许使用Instaclustr 的 Cassandra LDAP Authenticator，从 Cassandra 的lib/目录（在每个节点上）中引用它。试试看。