В NiFi имеется ряд процессоров, которые позволяют извлекать данные из таблиц базы данных с помощью драйвера JDBC, например, ExecuteSQL, QueryDatabaseTable и GenerateTableFetch. Начиная с NiFi 1.9.0, есть также процессор PutCassandraRecord, поэтому вы можете помещать свои данные непосредственно в Cassandra (без необходимости писать CQL).