Remove kafka sql upgrader

Apicurio · Sep 21, 2023 · d728472 · d728472
1 parent f14c03b
commit d728472
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 61 deletions.
diff --git a/...sql/src/main/java/io/apicurio/registry/storage/impl/kafkasql/KafkaSqlRegistryStorage.java b/...sql/src/main/java/io/apicurio/registry/storage/impl/kafkasql/KafkaSqlRegistryStorage.java
@@ -110,9 +110,6 @@ public class KafkaSqlRegistryStorage extends RegistryStorageDecoratorReadOnlyBas
     @Inject
     ArtifactStateExt artifactStateEx;
 
-    @Inject
-    KafkaSqlUpgrader upgrader;
-
     @Inject
     Event<StorageEvent> storageEvent;
 
@@ -228,7 +225,6 @@ private void startConsumerThread(final KafkaConsumer<MessageKey, MessageValue> c
                             if (record.key().getType() == MessageType.Bootstrap) {
                                 BootstrapKey bkey = (BootstrapKey) record.key();
                                 if (bkey.getBootstrapId().equals(bootstrapId)) {
-                                    upgrader.upgrade();
                                     this.bootstrapped = true;
                                     storageEvent.fireAsync(StorageEvent.builder()
                                             .type(StorageEventType.READY)

diff --git a/...e/kafkasql/src/main/java/io/apicurio/registry/storage/impl/kafkasql/KafkaSqlUpgrader.java b/...e/kafkasql/src/main/java/io/apicurio/registry/storage/impl/kafkasql/KafkaSqlUpgrader.java