第 19 章 Cassandra Sink

将数据发送到 Cassandra 集群。

此 Kamelet 预期正文为 JSON Array。JSON Array 的内容将用作查询参数中设置的 CQL Prepared Statement 的输入。

19.1. 配置选项

下表总结了 cassandra-sink Kamelet 可用的选项：

属性	名称	描述	类型	默认	示例
connectionHost *	连接主机	hostname (s) cassandra server (s)。可以使用逗号分隔多个主机。	字符串		`"localhost"`
connectionPort *	连接端口	cassandra 服务器的端口号	字符串		`9042`
Keyspace *	键空间	要使用的键空间	字符串		`"customers"`
password *	密码	用于访问安全 Cassandra 集群的密码	字符串
query *	查询	要针对 Cassandra 集群表执行的查询	字符串
username *	用户名	用于访问安全 Cassandra 集群的用户名	字符串
consistencyLevel	一致性级别	要使用的一致性级别。该值可以是 ANY, ONE, TWO, THREE, QUORUM, ALL, LOCAL_QUORUM, EACH_QUORUM, SERIAL, LOCAL_SERIAL, LOCAL_ONE	字符串	`"ANY"`

注意

标有星号 integrity 的字段是必需的。