第 15 章 Cassandra Sink
将数据发送到 Cassandra 集群。
这个 Kamelet 预期正文为 JSON Array。JSON Array 的内容将用作查询参数中设置的 CQL 准备语句的输入。
15.1. 配置选项
下表总结了可用于 cassandra-sink Kamelet 的配置选项：
| 属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
|---|---|---|---|---|---|
| connectionHost * | 连接主机 | 主机名(s)sandssandra server）。可以使用逗号分隔多个主机。 | 字符串 |
| |
| connectionPort * | 连接端口 | cassandra 服务器的端口号 | 字符串 |
| |
| keyspace * | keyspace | 要使用的密钥空间 | 字符串 |
| |
| 密码 * | 密码 | 用于访问安全 Cassandra 集群的密码 | 字符串 | ||
| 查询 * | 查询 | 要对 Cassandra 集群表执行的查询 | 字符串 | ||
| 用户名 * | 用户名 | 用于访问安全 Cassandra 集群的用户名 | 字符串 | ||
| consistencyLevel | 致性级别 | 要使用的一致性级别。该值可以是 ANY、ONE、TWO、THREE、QUORUM、ALL、LOCAL_QUORUM、EACH_QUORUM、SERIAL、LOCAL_SERIAL, LOCAL_SERIAL, LOCAL_ONE | 字符串 |
|
带有星号(*)标记的字段为必填。
