C# 将 AVRO 转换为 JSON

Question

是否有 C# 实现来转换 AVRO 反序列化

<GenericRecord>

回到常规的 JSON 格式？我已经成功阅读了来自 Kafka 的主题并使用了AvroDeserializer，但我想将其转换为 JSON 格式。

这是一个例子： 简单的 JSON：

{       
        "value": {
            "eventCreatedTimestamp": 1588694347577,
            "iouDecision": "PLANE",
            "iouDecisionReason": {
                "value": "Optimal"
            }
        }
    }

与 AVRO 反序列化的 Generic.Record 相同：

{Schema: 
{"type":"record","name":"TheCustomerDecisionEvent",
"namespace":"com.farmxxx.tst.property.service.options.iou.messaging.avro","fields":
[{"name":"eventCreatedTimestamp","type":["null","long"]},
{"name":"iouDecision","type":["null",{"type":"enum",
"name":"TheType",
"namespace":"com.farmxxx.tst.property.service.options.iou.messaging.avro",
"symbols":["HRMR","FIELD","PLANE"]}]},
{"name":"iouDecisionReason","type":["null",{"type":"record","name":"iouDecisionReason",
"namespace":"com.farmxxx.tst.property.service.options.iou.messaging.avro",
"fields":[{"name":"value","type":["null","string"]}]}]}]}
,
 contents: { eventCreatedTimestamp: 1588694347577, 
 iouDecision: Schema: {"type":"enum","name":"TheType",
 "namespace":"com.farmxxx.tst.property.service.options.iou.messaging.avro",
 "symbols":["HRMR","FIELD","PLANE"]}, value: PLANE,
 iouDecisionReason: Schema: {"type":"record","name":"iouDecisionReason",
"namespace":"com.farmxxx.tst.property.service.options.iou.messaging.avro",
"fields":[{"name":"value","type":["null","string"]}]}, contents: { value: Optimal, }, }}

所以任务是从 AVRO Generic.Record 返回到 Simple JSON。

Answer 1

可以使用以下方法找到解决方案：

https://github.com/AdrianStrugala/AvroConvert

Avro2Json 功能。

通过它，您可以从 Kafka 读取主题并将其转换为简单的 JSON。 我使用那个简单的 JSON 传递给其他不想了解 AVRO 记录格式等的客户。

非常感谢 AvroConvert Github 存储库的作者。

Answer 2

正如 cmets 中所建议的，我过去曾为此使用过 https://github.com/kristofferjalen/AvroConverter（我与该项目无关）。

该页面的自述文件表明它非常易于使用。只需在包管理器命令行中输入Install-Package AvroConverter（如果不使用 Visual Studio，则输入您的 CLI）从 NuGet 安装其包，然后从您的代码中使用以下代码调用它：

var path = @"C:\your\avro\file\path.avro";
var fileInfo = new System.IO.FileInfo(path);
var json = AvroConvert.ToJson(fileInfo);