Search code examples
schemaapache-nifiavrocsvreader

Error encountered when configuring csvReader to use the Avro schema registry in Apache Nifi

csvReader property set: enter image description here

Here is the schema I created and registered in AvroSchemaRegistry

{ "namespace": "nifi", "type": "record", "name": "users", "fields" : [ {"name": "first_name", "type": "string"}, {"name": "last_name", "type": "string"}, {"name": "age", "type": "int"} ] }

Error I encountered upon running the Apache-nifi processor

org.apache.nifi.schema.access.SchemaNotFoundException: FlowFile did not contain appropriate attributes to determine Schema Text

Solution

  • Configure your CSVReader as -

    Schema Access Strategy = Use 'Schema Name' Property

    Schema Registry = Your AvroSchemaRegistry Controller Service

    Schema Name = users

    Schema Text = let it be default value

    This means CSVReader will search schema registry for the specified schema name since the access strategy is the schema name, and we are passing it to the registry.