我有一个java kafka streams应用程序,它消耗了一个C#应用程序产生的avro事件。在C#上,它是一个内置的avro库。对于Date类型的字段,它生成avro模式到 { "name": "dateOfBirth", "type": "int" }
而没有logicalType。显然,这在java消费端造成了麻烦。
我想请教一下使用AVRO C#的人,标准C# avro lib生成的日期字段的avro模式是什么?
很明显,这在java消费者端会引起麻烦。
不应该的。模式注册表会按原样存储该模式,然后消费者会将该数据作为一个整数读取。
然而,我想指出的是,日期应该是 long
,表示为unix epoch。
由标准的C# avro lib来表示?
这正是C# confluent-dotnet所使用的,AFAIK;他们没有重新编写自己的