0

我是 Kafka 和 Avro 序列化和反序列化的新手。我在 .NET 中有以下类定义

    public class GWRequestData
    {
      public string GWSerialNumber {get;set;}
      public string RequestId {get;set;}
      public int ServiceId {get;set;}
      public int HandlerId {get;set;}
      public object[] RequestParams {get;set;}
    }

我有多个生产者,它们为网关产生不同类型的请求。每个请求都会有不同的请求参数,这些参数将根据&object[]的组合在中定义。有一个消费者与网关连接的系统交互,通过它我们可以向网关发送请求。ServiceIdHandlerId

现在我想.avsc为上述数据结构以文件的形式生成 Avro 模式定义,以便所有 GWRequest 必须由生产者在单个主题上发布。我找不到object[] Requestparams在 Avro 中定义的任何线索。

谢谢你的帮助。

4

0 回答 0