Hello,
I am using the below Avro schema to insert records to cassandra using PutCassandraRecord processor, here this column is uuid datatype in cassandra database but nifi is not able to resolve this datatype and the getting this error
PutCassandraRecord[id=676539f3-2fc7-173e-8d3f-2e703922f111] Unable to write the records into Cassandra table due to com.datastax.driver.core.exceptions.InvalidQueryException: UUID should be 16 or 0 bytes (36)
- Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: UUID should be 16 or 0 bytes (36): {}
Avro Schema defined in AvroSchemaRegistry
{
"type": "record",
"name": "provenance_event",
"namespace": "provenanceRecords",
"fields": [{
"name": "id",
"type": ["null", {"type": "string", "logicalType": "uuid"}],
"default": null
}]
}
NiFI avro schema is not able to convert string datatype to uuid
Sample JSON which I sending
[ { "id" : "5b616957-2a98-4a9e-97c8-2d2333966a0f" }]
I am on NiFi 1.16.3 version
@MattWho@Bryan Bende