我有一个具有此属性的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模式的逻辑类型吗?谢谢。
1条答案
按热度按时间tkclm6bt1#
它是一个逻辑类型,我认为您只需要将它声明为一个逻辑类型。