Custom schema storage

    为了使用Pulsar schema的非默认 (即非BookKeeper) 存储系统, 您需要实现两个 Java 接口: SchemaStorage 和 。

    1. @NotNull
    2. }

    为了适应你自定义的schema存储实现,你需要:

    1. 将jar添加到Pulsar二进制或源码lib文件夹中。
    2. 在配置中将修改为你自定义的factory类(即SchemaStorageFactory的实现,而不是SchemaStorage的实现)。
    3. 启动Pulsar。