Skip to main content
Version: Next

Cassandra

Cassandra source connector

Description

Read data from Apache Cassandra.

Key features

Options

nametyperequireddefault value
hostStringYes-
keyspaceStringYes-
cqlStringYes-
usernameStringNo-
passwordStringNo-
datacenterStringNodatacenter1
consistency_levelStringNoLOCAL_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