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

  1. source {
  2.  Cassandra {
  3.      host = "localhost:9042"
  4.      username = "cassandra"
  5.      password = "cassandra"
  6.      datacenter = "datacenter1"
  7.      keyspace = "test"
  8.      cql = "select * from source_table"
  9.      result_table_name = "source_table"
  10.     }
  11. }

Changelog

next version

  • Add Cassandra Source Connector