使用.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
1条答案
按热度按时间evrscar21#
这是一个问题,因为我们试图使用嵌套Map,如@panagiotiskanavos。
将架构更改为使用记录类型的Map已经解决了我的问题。
谢谢你的帮助