第 18 章 Cassandra Sink

将数据发送到 Apache Cassandra 集群。

此 Kamelet 需要 JSON Array 格式的数据。JSON Array 的内容用作查询参数中设置的 CQL Prepared Statement 的输入。

18.1. 配置选项
复制链接

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

Expand

属性	名称	描述	类型	默认	示例
connectionHost *	连接主机	Cassandra 服务器的主机名。使用逗号分隔多个主机名。	字符串		localhost
connectionPort *	连接端口	cassandra 服务器的端口号。使用逗号分隔多个端口号。	字符串		9042
Keyspace *	键空间	要使用的键空间。	字符串		客户
query *	查询	要针对 Cassandra 集群表执行的查询。	字符串
consistencyLevel	一致性级别	要使用的一致性级别。	字符串	ANY
extraTypeCodecs	额外类型代码cs	使用特定逗号分隔的 Extra Type codecs 列表。	字符串
jsonPayload	JSON Payload	如果要在 json 中转换有效负载	布尔值	True
password	密码	用于访问安全 Cassandra 集群的密码。	字符串
prepareStatements	准备声明	如果为 true，则指定使用 PreparedStatements 作为查询。如果为 false，指定使用常规声明作为查询。	布尔值	True
username	用户名	用于访问安全 Cassandra 集群的用户名。	字符串

* = 标记为星号的字段 是必需的。

返回顶部