在向 Kafka 生成 AVRO 数据时,Avro 序列化程序在写入数据时使用的字节数组中写入相同的架构 ID。
Kafka Consumer 根据接收到的字节数组中的模式 ID 从模式注册表中获取模式。因此,生产者和消费者等模式都使用相同的模式 ID。
但为什么很多文章都包括这个one https://dzone.com/articles/kafka-avro-serialization-and-the-schema-registry says 消费者的模式可能与生产者的不同。
请帮助我理解这一点。
Kafka Consumer根据模式ID从模式注册表中获取模式
仅当您让解串器执行此操作时。
您能够在消费者代码中定义自己的兼容模式。因此,它可能会有所不同并遵循 Avro 模式演化规则
模式演变仅在消费者(读取)的反序列化过程中发生。如果消费者的模式与生产者的模式不同,则在反序列化期间会自动修改值或键,以尽可能符合消费者的读取模式。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)