关于Avroschema理解

在做kafka Connect的时候&＃xff0c;关于schema registry有几个疑问&＃xff1a;

1. schema是个什么&＃xff0c;在Avro里面起到了什么作用&＃xff1f;

2. schema registry是怎么管理的&＃xff1f;

首先第一个问题&＃xff1a;

了解一下avro&＃xff1a;

https://blog.kazaff.me/2014/07/07/%E6%98%AF%E4%BB%80%E4%B9%88%E7%B3%BB%E5%88%97%E4%B9%8BAvro/

然后什么是schema&＃xff1a;

https://zhuanlan.zhihu.com/p/24803426

然后是第二个问题&＃xff1a;

我们把所有写入数据需要用到的schema保存在Registry中&＃xff0c;然后我们把唯一标识Schema的ID存储在record中发送给kafka。这样的话&＃xff0c;利用该ID&＃xff0c;我们就可以在需要消费该数据的时候从Schema Registry中拉取合适的schema来反序列化数据。这些标志schema的ID保存在topic中。如下&＃xff1a;