VERSION

Features

  • Use Cassandra sink connector to sync data from Pulsar

Tags

Pulsar IO

Cassandra

Sink

Enterprise Support

StreamNative supported

Author

[ "ASF" ]

Cassandra Sink

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

Name Type Required Default Description
roots String true " " (empty string) A comma-separated list of Cassandra hosts to connect to.
keyspace String true " " (empty string) The key space used for writing pulsar messages.

Note: keyspace should be created prior to a Cassandra sink.
keyname String true " " (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.
columnFamily String true " " (empty string) The Cassandra column family name.

Note: columnFamily should be created prior to a Cassandra sink.
columnName String true " " (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.