0

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

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

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

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

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

4

1 回答 1

0

将您的 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 将在模式注册表中搜索指定的模式名称,因为访问策略是模式名称,我们将其传递给注册表。

于 2021-07-01T15:31:44.777 回答