AvroData 用架构默认值替换空值

Question

我正在使用 io.confluent.connect.avro.AvroData.fromConnectData 在序列化之前转换消息。 AvroData 使用 struct.get(field) 来获取值，然后用架构默认值替换空值。

正如我从 avro doc 中了解到的，当阅读器期望写入器模式中缺少的字段（不是特定消息）时，应该使用默认值来实现模式兼容性。

所以我的问题是：用架构默认值替换空值是否正确？或者我应该使用其他方式来转换消息？

Answer 1

错过的理解是默认值不是用来替换空值的，它是用来填充你的字段值，以防你的数据不包含该字段。这主要用于模式演变目的。您正在尝试做的事情（将作为数据的一部分出现的空值替换为另一个值）是不可能通过 avro 模式实现的，您需要在程序中处理它。