在 Nifi 中将 JSON 转换为 Avro答案

【问题标题】：Convert JSON to Avro in Nifi在 Nifi 中将 JSON 转换为 Avro
【发布时间】：2020-08-25 06:08:49
【问题描述】：

我想将 json 数据转换为 avro。我使用了 GenerateFlowFile 并输入了虚拟 json 值 [{"firstname":"prathik","age":21},{"firstname":"arun","age":22}]。然后我使用了 ConvertRecord 处理器并使用 AvroSchemaRegistry 设置 JsonTreeReader 和 AvroRecordSetWriter，它具有以下架构：AvroScehma

但我将其作为我的输出：Output (Avro Data)

我是 Apache Nifi 的新手。提前致谢。

【问题讨论】：

设置您的 AvroRecordSetWriter 以嵌入 Avro Schema。然后应该可以看到转换后的数据（格式化）
感谢您的意见。我已将 AvroRecordSetWriter 中的写入策略设置为 Embedded Avro。我收到了以下输出： Objavro.schema€{"type":"record","name":"person","namespace":"nifi","fields":[{"name":"firstname" ,"type":"string"},{"name":"age","type":"int"}]}avro.codecnull¢ÈFB¡-Ž0„Ûv‚L@prathik*arun,¢ÈFB¡-Ž0„Ûv‚L@ 又是红点.
您使用的是哪个 NiFi 版本？能否提供JsonTreeReader和AvroRecordSetWriter的配置？

标签： json apache-nifi avro apache-nifi-registry

【解决方案1】：

但我得到这个作为我的输出：输出（Avro 数据）

这是意料之中的。 Avro 是一种二进制文件格式，您所看到的是试图以文本格式显示该数据。应该是这样的。

【讨论】：