问题描述
我想使用HandleHTTP处理器在Nifi中托管API。我想传递一些虚拟json数据。我想将JSON数据转换为avro，然后将其推送到S3存储桶。
当json数据从HandleHTTPResponse转换为ConvertRecord时，出现以下错误（正在转换json-> Avro），因此数据进入了该失败管道。
有人可以帮我吗？
解决方法
这意味着在ConvertRecord中，您有一个配置为“模式名称”的“模式访问策略”的记录读取器，并且您将“模式名称”属性设置为默认值“ $ {schema.name}”，但是您的流文件没有schema.name作为属性。
如果知道所有时间都相同，则可以将“模式名称”更改为模式名称的硬编码值，也可以将schema.name作为请求的标头发送给HandleHttpRequest，然后将schema.name用作属性。