Cassandra sink connector

Description

Write data to Apache Cassandra.

Key features

Options

name type required default value
host String Yes -
keyspace String Yes -
table String Yes -
username String No -
password String No -
datacenter String No datacenter1
consistency_level String No LOCAL_ONE
fields String No LOCAL_ONE
batch_size int No 5000
batch_type String No UNLOGGED
async_write boolean No true

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.

table [String]

The Cassandra table name.

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.

fields [array]

The data field that needs to be output to Cassandra , if not configured, it will be automatically adapted according to the sink table schema.

batch_size [number]

The number of rows written through Cassandra-Java-Driver each time, default is 5000.

batch_type [String]

The Cassandra batch processing mode, default is UNLOGGER.

async_write [boolean]

Whether cassandra writes in asynchronous mode, default is true.

Examples

  1. sink {
  2. Cassandra {
  3. host = "localhost:9042"
  4. username = "cassandra"
  5. password = "cassandra"
  6. datacenter = "datacenter1"
  7. keyspace = "test"
  8. }
  9. }

Changelog

next version

  • Add Cassandra Sink Connector