diff --git a/pkg/config/config.go b/pkg/config/config.go
index 1a32a117..0dac8f83 100644
--- a/pkg/config/config.go
+++ b/pkg/config/config.go
@@ -109,6 +109,9 @@ func (c *Config) validateSetDefaults() error {
 			return fmt.Errorf("unknown schema store type %q", c.SchemaStore.Type)
 		}
 	}
+	if c.SchemaStore != nil && c.SchemaStore.UploadPath == "" {
+		c.SchemaStore.UploadPath = "/schemas"
+	}
 	if c.SchemaStore == nil && (c.GRPCServer.SchemaServer == nil || !c.GRPCServer.SchemaServer.Enabled) {
 		return errors.New("schema-server RPCs cannot be exposed if the schema server is not enabled")
 	}
diff --git a/pkg/server/schema.go b/pkg/server/schema.go
index 67580c82..e2af82b0 100644
--- a/pkg/server/schema.go
+++ b/pkg/server/schema.go
@@ -49,10 +49,10 @@ func (s *Server) createLocalSchemaStore(ctx context.Context) {
 	var store schemaStore.Store
 	switch s.config.SchemaStore.Type {
 	case schemaConfig.StoreTypeMemory:
-		store = schemaMemoryStore.New()
+		store = schemaMemoryStore.New(s.config.SchemaStore.UploadPath)
 	case schemaConfig.StoreTypePersistent:
 		var err error
-		store, err = schemaPersistentStore.New(ctx, s.config.SchemaStore.Path, s.config.SchemaStore.Cache)
+		store, err = schemaPersistentStore.New(ctx, s.config.SchemaStore.UploadPath, s.config.SchemaStore.Path, s.config.SchemaStore.Cache)
 		if err != nil {
 			log.Errorf("failed to create a persistent schema store: %v", err)
 			os.Exit(1)