Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
The Cassandra sink connector pulls messages from Pulsar topics to Cassandra clusters
| 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. |
{
"roots": "localhost:9042",
"keyspace": "pulsar_test_keyspace",
"columnFamily": "pulsar_test_table",
"keyname": "key",
"columnName": "col"
}
configs:
roots: "localhost:9042"
keyspace: "pulsar_test_keyspace"
columnFamily: "pulsar_test_table"
keyname: "key"
columnName: "col"
Was this page helpful?