Fix a kafkasql import bug

Apicurio · Mar 7, 2024 · f2cb314 · f2cb314
1 parent 82f6634
commit f2cb314
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/app/src/main/java/io/apicurio/registry/storage/impl/kafkasql/KafkaSqlRegistryStorage.java b/app/src/main/java/io/apicurio/registry/storage/impl/kafkasql/KafkaSqlRegistryStorage.java
@@ -746,7 +746,8 @@ public void importGlobalRule(GlobalRuleEntity entity) {
      */
     @Override
     public void importContent(ContentEntity entity) {
-        var message = new ImportContent1Message(entity);
+        String content = ContentHandle.create(entity.contentBytes).content();
+        var message = new ImportContent1Message(entity, content);
         var uuid = ConcurrentUtil.get(submitter.submitMessage(message));
         coordinator.waitForResponse(uuid);
     }

diff --git a/.../main/java/io/apicurio/registry/storage/impl/kafkasql/messages/ImportContent1Message.java b/.../main/java/io/apicurio/registry/storage/impl/kafkasql/messages/ImportContent1Message.java
@@ -1,5 +1,6 @@
 package io.apicurio.registry.storage.impl.kafkasql.messages;
 
+import io.apicurio.registry.content.ContentHandle;
 import io.apicurio.registry.storage.RegistryStorage;
 import io.apicurio.registry.storage.impl.kafkasql.AbstractMessage;
 import io.apicurio.registry.utils.impexp.ContentEntity;
@@ -21,12 +22,14 @@
 public class ImportContent1Message extends AbstractMessage {
 
     private ContentEntity entity;
+    private String content;
 
     /**
      * @see io.apicurio.registry.storage.impl.kafkasql.KafkaSqlMessage#dispatchTo(io.apicurio.registry.storage.RegistryStorage)
      */
     @Override
     public Object dispatchTo(RegistryStorage storage) {
+        entity.contentBytes = ContentHandle.create(content).bytes();
         storage.importContent(entity);
         return null;
     }