Custom schema storage
为了使用Pulsar schema的非默认 (即非BookKeeper) 存储系统, 您需要实现两个 Java 接口: SchemaStorage 和 。
@NotNull
}
为了适应你自定义的schema存储实现,你需要:
- 将jar添加到Pulsar二进制或源码的
lib
文件夹中。 - 在配置中将修改为你自定义的factory类(即
SchemaStorageFactory
的实现,而不是SchemaStorage
的实现)。 - 启动Pulsar。