Skip to main content

Cassandra sink connector

The Cassandra sink connector pulls messages from Pulsar topics to Cassandra clusters.

Configuration​

The configuration of the Cassandra sink connector has the following properties.

Property​

NameTypeRequiredDefaultDescription
rootsStringtrue" " (empty string)A comma-separated list of Cassandra hosts to connect to.
keyspaceStringtrue" " (empty string)The key space used for writing pulsar messages.

Note: keyspace should be created prior to a Cassandra sink.
keynameStringtrue" " (empty string)The key name of the Cassandra column family.

The column is used for storing Pulsar message keys.

If a Pulsar message doesn't have any key associated, the message value is used as the key.
columnFamilyStringtrue" " (empty string)The Cassandra column family name.

Note: columnFamily should be created prior to a Cassandra sink.
columnNameStringtrue" " (empty string)The column name of the Cassandra column family.

The column is used for storing Pulsar message values.

Example​

Before using the Cassandra sink connector, you need to create a configuration file through one of the following methods.

  • JSON


    {
    "roots": "localhost:9042",
    "keyspace": "pulsar_test_keyspace",
    "columnFamily": "pulsar_test_table",
    "keyname": "key",
    "columnName": "col"
    }

  • YAML


    configs:
    roots: "localhost:9042"
    keyspace: "pulsar_test_keyspace"
    columnFamily: "pulsar_test_table"
    keyname: "key"
    columnName: "col"

Usage​

For more information about how to connect Pulsar with Cassandra, see here.