Cassandra Sink

This sink application writes the content of each message it receives into Cassandra.

It expects a payload of JSON String and uses it’s properties to map to table columns.

A JSON String or byte array representing the entity (or a list of entities) to be persisted.

Options

The cassandra sink has the following options:

spring.data.cassandra.compression: Compression supported by the Cassandra binary protocol. (Compression, default: none, possible values: LZ4,SNAPPY,NONE)
spring.data.cassandra.config: Location of the configuration file to use. (Resource, default: <none>)
spring.data.cassandra.contact-points: Cluster node addresses in the form 'host:port', or a simple 'host' to use the configured port. (List<String>, default: [127.0.0.1:9042])
spring.data.cassandra.keyspace-name: Keyspace name to use. (String, default: <none>)
spring.data.cassandra.local-datacenter: Datacenter that is considered "local". Contact points should be from this datacenter. (String, default: <none>)
spring.data.cassandra.password: Login password of the server. (String, default: <none>)
spring.data.cassandra.port: Port to use if a contact point does not specify one. (Integer, default: 9042)
spring.data.cassandra.schema-action: Schema action to take at startup. (String, default: none)
spring.data.cassandra.session-name: Name of the Cassandra session. (String, default: <none>)
spring.data.cassandra.ssl: Enable SSL support. (Boolean, default: false)
spring.data.cassandra.username: Login user of the server. (String, default: <none>)