无法从date生成avro架构对象

eblbsuwk  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(342)

我有一个具有此属性的avro架构:

{"name": "whenDate", "type": ["date", "null"]}

我使用的是python客户机和producer

confluent_kafka.avro.AvroProducer

当我加载具有上述属性的avro模式时,会触发以下错误:

not a valid Avro schema: Type property "[u'date', u'null']" not a valid 
Avro schema: Union item must be a valid Avro schema: Could not make an Avro Schema object from date.

我假设这个错误说明了avro模式的汇合解析器的局限性。也就是说, date 是此处指定的逻辑类型,但合流解析器尚未支持它。
有人能证实吗?更一般地说,我应该假设汇合解析器不处理avro模式的逻辑类型吗?谢谢。

tkclm6bt

tkclm6bt1#

它是一个逻辑类型,我认为您只需要将它声明为一个逻辑类型。

{"name": "date", "type": "int", "logicalType": "date"}

相关问题