无法从日期创建 Avro Schema 对象

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"}