Hey, As a learning exercise, I've created a flow that parses a kafka topic of json messages and inserts them into Cassandra. It's a three column table: id (text), ts (timestamp), and value (float). I set cql.args.x.type to the proper data types for each column.
PutCassandraQL is failing with the following: org.apache.nifi.processor.exception.ProcessException: The value of the cql.args.2.value is '2016-06-21T20:23:41Z', which cannot be converted into the necessary data type: timestamp This happens for each timestamp, but I'm pretty sure the format is correct. It's in ISO-8601, and I'm able to insert them manually into the c* table. I'm on Nifi 0.6.1. Any help would be appreciated, thanks!
