Skip to content
This repository was archived by the owner on Feb 26, 2026. It is now read-only.

Latest commit

 

History

History
20 lines (12 loc) · 674 Bytes

File metadata and controls

20 lines (12 loc) · 674 Bytes

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.

Payload

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: