使用各种 Avro 的模式来消费一个主题和一个模式答案

【问题标题】：Using various Avro's schemas to consume one topic and one schema使用各种 Avro 的模式来消费一个主题和一个模式
【发布时间】：2020-04-12 14:17:33
【问题描述】：

我对 Kafka 的消费者有些困惑。我可以使用各种模式来使用模式注册表使用一个主题吗？

发布：

完整架构：

{
    Name: "",
    Sex: "",
    Phone: "",
    Address: ""
}

消费：

架构 A：

{
    Name: "", 
    Phone:""
}

架构 B：

{
    Name: "",
    Sex:"", 
    Address:""
}

【问题讨论】：

【解决方案1】：

使用 Avro 时，您有一个写入器和读取器模式。当阅读器只定义一个字段的子集时，这些字段按名称匹配，并且是唯一反序列化的字段

【讨论】：

【解决方案2】：

您必须在两侧使用相同的架构。使用您的示例，使用模式 A 的反序列化器不会知道它需要跳过一些代表性别的字节才能到达代表电话的字节。

反序列化器的实现可以通过忽略数据反序列化到没有性别字段的对象，但它必须知道字节数组包含它，这是架构提供的。

【讨论】：