schema - 将 csvReader 配置为在 Apache Nifi 中使用 Avro 模式注册表时遇到错误

Question

csvReader 属性集： 在此处输入图像描述

这是我在 AvroSchemaRegistry 中创建和注册的架构

{“命名空间”：“nifi”，“类型”：“记录”，“名称”：“用户”，“字段”：[ {“名称”：“名字”，“类型”：“字符串”}，{“名称”：“姓氏”，“类型”：“字符串”}，{“名称”：“年龄”，“类型”：“int”}] }

我在运行 Apache-nifi 处理器时遇到的错误

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

Answer 1

将您的 CSVReader 配置为 -

Schema Access Strategy=Use 'Schema Name' Property

Schema Registry=Your AvroSchemaRegistry Controller Service

Schema Name=users

Schema Text=let it be default value

这意味着 CSVReader 将在模式注册表中搜索指定的模式名称，因为访问策略是模式名称，我们将其传递给注册表。