Ff2Cql

A simple transfer data from NiFi FlowFile to CQL (support Apache Cassandra, ScyllaDB, AstraDB, etc.). The implementation details:

development NiFi v2 processor (with controller) and java application (support Java 17/21+)
support Apache Cassandra v4/v5, ScyllaDB, AstraDB based on CQL (Cassandra Query Language)

1. The main motivation

the Apache NiFi v2 does not support Apache Cassandra v4/v5 (NiFi v2 removed the Cassandra processor due to security vulnerabilities and unmaintained code. The processor supported only Cassandra v3 not newer.)

2. Usage in NiFi

You can use this preferred way:

✅ PutCQL as NiFi processor with controller (download last version, see 'nifi-cql-nar-*.nar'), where inputs are FlowFiles (addition detail)

or two other alternative ways:

✅ ExecuteProcess with java application (see 'Ff2Cql-*.jar'), where inputs are CSV files (addition detail)
✅ ExecuteStreamCommand with java application (see 'Ff2Cql-*.jar'), where inputs are FlowFiles via stdin (addition detail)