Ff2Cql

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

development as java application and NiFi v2 processor (support Java 17 and 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)

2. Usage in NiFi

You can use this prefered way:

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

or two other alternative ways:

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