无法从日期创建 Avro 架构对象

Question

我有一个 Avro 架构 属性:

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

我正在使用 Python 客户端和生产者

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 模式的 Confluent 解析器的局限性。也就是说，date 是指定的逻辑类型 here，但 Confluent 解析器尚不支持它。

谁能证实一下？更一般地说，我是否应该假设 Confluent 解析器不处理 Avro 模式的逻辑类型？谢谢。

Answer 1

这是一个逻辑类型，我想你只需要将它声明为一个即可。

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