Skip to main content

Cassandra Sink Connector

The Cassandra Sink connector is used to write messages to a Cassandra Cluster.

The tutorial Connecting Pulsar with Apache Cassandra shows an example how to use Cassandra Sink connector to write messages to a Cassandra table.

Sink Configuration Options​

All the Cassandra sink settings are listed as below. All the settings are required to run a Cassandra sink.

NameDefaultRequiredDescription
rootsnulltrueCassandra Contact Points. A list of one or many node address. It is a comma separated String.
keyspacenulltrueCassandra Keyspace name. The keyspace should be created prior to creating the sink.
columnFamilynulltrueCassandra ColumnFamily name. The column family should be created prior to creating the sink.
keynamenulltrueKey column name. The key column is used for storing Pulsar message keys. If a Pulsar message doesn't have any key associated, the message value will be used as the key.
columnNamenulltrueValue column name. The value column is used for storing Pulsar message values.