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

    @NotNull
    SchemaStorage create(PulsarService pulsar) throws Exception;

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

1. 将实现打包到 文件中。
2. 将jar添加到Pulsar二进制或源码的lib文件夹中。
3. 启动Pulsar。