Avro：可空时间戳字段的未知数据类型 org.joda.time.DateTime

Question

当 Timestamp 类型的字段可为空时，序列化会失败（下面的跟踪和架构），并且在将该字段更改为强制字段后错误消失。请帮助理解这个问题。

错误：

Caused by: org.apache.kafka.common.errors.SerializationException: Error serializing Avro message
Caused by: org.apache.avro.AvroRuntimeException: Unknown datum type org.joda.time.DateTime: 2011-06-07T00:00:00.000Z
    at org.apache.avro.generic.GenericData.getSchemaName(GenericData.java:757)
    at org.apache.avro.specific.SpecificData.getSchemaName(SpecificData.java:314)
    at org.apache.avro.generic.GenericData.resolveUnion(GenericData.java:721)
    at org.apache.avro.generic.GenericDatumWriter.resolveUnion(GenericDatumWriter.java:205)
    at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:123)
    at org.apache.avro.specific.SpecificDatumWriter.writeField(SpecificDatumWriter.java:87)
    at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:156)
    at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:118)
    at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:75)
    at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:62)
    at io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:101)
    at io.confluent.kafka.serializers.KafkaAvroSerializer.serialize(KafkaAvroSerializer.java:53)
    at io.confluent.kafka.streams.serdes.avro.SpecificAvroSerializer.serialize(SpecificAvroSerializer.java:65)

模式

{
  "name": "shipdate",
  "type": [
    "null",
    {
      "type": "long",
      "connect.version": 1,
      "connect.name": "org.apache.kafka.connect.data.Timestamp",
      "logicalType": "timestamp-millis"
    }
  ],
  "default": null
}

环境

• 爪哇1.8
• 阿帕奇maven 3.5.2
• Avro 1.8.2 还使用 1.9.0-SNAPSHOT 进行了测试
• avro-maven-插件
• 卡夫卡流 2.0.0-cp1