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上。

相关推荐