红帽全球峰会15. Cassandra Sink
将数据发送到 Cassandra 集群。
此 Kamelet 预期正文为 JSON Array。JSON Array 的内容将用作查询参数中设置的 CQL Prepared Statement 的输入。
15.1. 配置选项
下表总结了 cassandra-sink Kamelet 可用的选项：
| 属性 | 名称 | 描述 | 类型 | 默认 | Example |
|---|---|---|---|---|---|
| connectionHost * | 连接主机 | hostname (s) cassandra server (s)。可以使用逗号分隔多个主机。 |
|
| |
| connectionPort * | 连接端口 | cassandra 服务器的端口号 |
|
| |
| Keyspace * | 键空间 | 要使用的键空间 |
|
| |
| query * | 查询 | 要针对 Cassandra 集群表执行的查询 |
| ||
| password | 密码 | 用于访问安全 Cassandra 集群的密码 |
| ||
| username | 用户名 | 用于访问安全 Cassandra 集群的用户名 |
| ||
| consistencyLevel | 一致性级别 | 要使用的一致性级别。该值可以是 ANY, ONE, TWO, THREE, QUORUM, ALL, LOCAL_QUORUM, EACH_QUORUM, SERIAL, LOCAL_SERIAL, LOCAL_ONE | string |
| |
| prepareStatements | 准备声明 | 如果为 true，则指定使用 PreparedStatements 作为查询。如果为 false，指定使用常规声明作为查询。 | 布尔值 |
| |
| extraTypeCodecs | 额外类型代码cs | 使用特定逗号分隔的 Extra Type codecs 列表。 | string |
| |
| jsonPayload | JSON Payload | 如果要在 json 中转换有效负载 | 布尔值 |
|
* = 标记为星号的字段 是必需的。
15.2. 依赖项
在运行时，cassandra-sink Kamelet 依赖于以下依赖项：
- camel:jackson
- camel:kamelet
- camel:cassandraql
- camel:core
15.3. kamelets 源文件
https://github.com/apache/camel-kamelets/blob/4.8.x/kamelets/cassandra-sink.kamelet.yaml
