Skip to main content

cassandra

EXPERIMENTAL

This component is experimental and therefore subject to change or removal outside of major version releases.

Executes a find query and creates a message for each row received.

# Common config fields, showing default values
input:
label: ""
cassandra:
addresses: []
query: ""
timeout: 600ms

Examples

Let's presume that we have 3 Cassandra nodes, like in this tutorial by Sebastian Sigl from freeCodeCamp:

https://www.freecodecamp.org/news/the-apache-cassandra-beginner-tutorial/

Then if we want to select everything from the table users_by_country, we should use the configuration below. If we specify the stdin output, the result will look like:

{"age":23,"country":"UK","first_name":"Bob","last_name":"Sandler","user_email":"bob@email.com"}

This configuration also works for Scylla.

input:
cassandra:
addresses:
- 172.17.0.2
query:
'SELECT * FROM learn_cassandra.users_by_country'

Fields

addresses

A list of Cassandra nodes to connect to.

Type: array

password_authenticator

Optional configuration of Cassandra authentication parameters.

Type: object

password_authenticator.enabled

Whether to use password authentication

Type: bool

password_authenticator.username

A username

Type: string

password_authenticator.password

A password

Secret

This field contains sensitive information that usually shouldn't be added to a config directly, read our secrets page for more info.

Type: string

disable_initial_host_lookup

If enabled the driver will not attempt to get host info from the system.peers table. This can speed up queries but will mean that data_centre, rack and token information will not be available.

Type: bool

query

A query to execute.

Type: string

max_retries

The maximum number of retries before giving up on a request.

Type: int

backoff

Control time intervals between retry attempts.

Type: object

backoff.initial_interval

The initial period to wait between retry attempts.

Type: string

backoff.max_interval

The maximum period to wait between retry attempts.

Type: string

timeout

Sorry! This field is missing documentation.

Type: string
Default: "600ms"

# Examples

timeout: 600ms