第 15 章 Cassandra Sink

将数据发送到 Cassandra 集群。

这个 Kamelet 预期正文为 JSON Array。JSON Array 的内容将用作查询参数中设置的 CQL 准备语句的输入。

15.1. 配置选项
复制链接

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

Expand

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

注意

带有星号(*)标记的字段为必填。

返回顶部