⭐️
Cassandra
Cassandra source connector
Description
Read data from Apache Cassandra.
Key features
Options
| name | type | required | default value |
|---|---|---|---|
| host | String | Yes | - |
| keyspace | String | Yes | - |
| cql | String | Yes | - |
| username | String | No | - |
| password | String | No | - |
| datacenter | String | No | datacenter1 |
| consistency_level | String | No | LOCAL_ONE |
host [string]
Cassandra cluster address, the format is host:port , allowing multiple hosts to be specified. Such as
"cassandra1:9042,cassandra2:9042".
keyspace [string]
The Cassandra keyspace.
cql [String]
The query cql used to search data though Cassandra session.
username [string]
Cassandra user username.
password [string]
Cassandra user password.
datacenter [String]
The Cassandra datacenter, default is datacenter1.
consistency_level [String]
The Cassandra write consistency level, default is LOCAL_ONE.
Examples
source {
Cassandra {
host = "localhost:9042"
username = "cassandra"
password = "cassandra"
datacenter = "datacenter1"
keyspace = "test"
cql = "select * from source_table"
result_table_name = "source_table"
}
}
Changelog
next version
- Add Cassandra Source Connector