第 14 章 Cassandra Sink

重要

Cassandra Sink Kamelet 只是一个技术预览功能。技术预览功能不受红帽产品服务等级协议（SLA）支持，且功能可能并不完整。红帽不推荐在生产环境中使用它们。

这些技术预览功能可以使用户提早试用新的功能，并有机会在开发阶段提供反馈意见。有关红帽技术预览功能支持范围的更多信息，请参阅 https://access.redhat.com/support/offerings/techpreview。

将数据发送到 Cassandra 集群。

此 Kamelet 需要将正文用作 JSON Array。JSON Array 的内容将用作查询参数中设置的 CQL Prepared 语句的输入。

14.1. 配置选项

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

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

注意

带星号(*)标记的字段是必需的。

返回顶部