Schema Registry

https://docs.confluent.io/current/schema-registry/docs/index.html#

 

什么是Schema Registry? 

 

Schema Registry 主要用于管理Avro的Schema. Schema不断的演变，Schema Registry可以把它的版本变化管理起来。同时它提供了一个Restful API接口，你可以通过这个Restful API接口来获取你需要版本的Avro Schema. 

 

Kafka client可以使用Schema Resgitry的plugin，这样所有Kafka client 发送接受的Avro msg使用的Schema都可以通过这个plugin来和Schema Registry相交互。你想获取Schema, 保存Schema都很方便，这些背后与Schema Registry的交互，对你这个Kafka client来说，完全是透明的，仿佛是本地一样。

 

Schema Registry就是保存Avro的Schema. 同时它是使用kafka来保存这些Schema的。

 

每个Schema都有一个global unique id. 顺序递增，不必连续。

 

Schema Registry是分布式的。但同时只有1个master - ZooKeeper和Kafka相互协调来选择master node. 

 

Schema ID的分配

Id分配永远发生在master node上。