Custom schema storage

    In order to use a non-default (i.e. non-BookKeeper) storage system for Pulsar schemas, you need to implement two Java interfaces: SchemaStorage and .

    1. public interface SchemaStorageFactory {
    3.     SchemaStorage create(PulsarService pulsar) throws Exception;

    In order to use your custom schema storage implementation, you’ll need to:

    1. Package the implementation in a JAR file.
    2. Add that jar to the folder in your Pulsar .
    3. Change the schemaRegistryStorageClassName configuration in broker.conf to your custom factory class (i.e. the SchemaStorageFactory implementation, not the implementation).