第 19 章 Cassandra Sink

将数据发送到 Cassandra 集群。

此 Kamelet 需要正文作为 JSON Array。JSON Array 的内容将用作查询参数中设置的 CQL 准备声明的输入。

19.1. 配置选项

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

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

注意

带有星号 packagemanifests 的字段是必需的。

返回顶部