apache-kafka - 无法从日期创建 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指定的逻辑类型，但 Confluent 解析器尚不支持它。

任何人都可以确认吗？更一般地说，我应该假设 Confluent 解析器不处理 Avro 模式的逻辑类型吗？谢谢。

Answer 1

它是一种逻辑类型，我认为您只需将其声明为一个。

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