如何在c中处理反序列化avroMap类型#

eqfvzcg8  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(447)

使用.net confluent kafka客户端处理项目,在反序列化avroMap类型时出现异常。有没有办法在c#中做到这一点?
该项目正在生产和消费Kafka的信息。除了Map类型之外,使用任何东西都没有问题。
avro架构片段:

{
    "name": "DurationMargins",
    "type": {
      "type": "map",
      "values": {
        "type": "map",
        "values": "double"
      }
    }
  },

avrogen由此创建以下属性:

private IDictionary<string,IDictionary<string,System.Double>> _DurationMargins;

但是,当尝试使用Kafka的消息时,会收到以下异常:

Avro.AvroException : Unable to find type IDictionary<string,System.Double> in all loaded assemblies in field DurationMargins
evrscar2

evrscar21#

这是一个问题,因为我们试图使用嵌套Map,如@panagiotiskanavos。
将架构更改为使用记录类型的Map已经解决了我的问题。
谢谢你的帮助

相关问题