fix: SandboxedSchemaRegistryClient does not impl. new registerWithRes…

…ponse SR API
confluentinc · Jun 23, 2023 · 877b381 · 877b381
1 parent a7bbc14
commit 877b381
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/...b-engine/src/main/java/io/confluent/ksql/schema/registry/DefaultSchemaRegistryClient.java b/...b-engine/src/main/java/io/confluent/ksql/schema/registry/DefaultSchemaRegistryClient.java
@@ -20,8 +20,12 @@
 import io.confluent.kafka.schemaregistry.client.SchemaMetadata;
 import io.confluent.kafka.schemaregistry.client.SchemaRegistryClient;
 import io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference;
+import io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse;
+import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException;
 import io.confluent.ksql.util.KsqlConfig;
 import io.confluent.ksql.util.KsqlSchemaRegistryNotConfiguredException;
+
+import java.io.IOException;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
@@ -68,6 +72,14 @@ public int register(final String s, final ParsedSchema parsedSchema, final int i
     throw configException;
   }
 
+  @Override
+  public RegisterSchemaResponse registerWithResponse(
+    final String subject,
+    final ParsedSchema schema,
+    final boolean normalize) throws IOException, RestClientException {
+    throw configException;
+  }
+
   @Override
   public ParsedSchema getSchemaById(final int i) {
     throw configException;

diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/services/SandboxedSchemaRegistryClient.java b/ksqldb-engine/src/main/java/io/confluent/ksql/services/SandboxedSchemaRegistryClient.java
@@ -22,6 +22,7 @@
 import io.confluent.kafka.schemaregistry.client.SchemaMetadata;
 import io.confluent.kafka.schemaregistry.client.SchemaRegistryClient;
 import io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference;
+import io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse;
 import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException;
 import java.io.IOException;
 import java.util.Collection;
@@ -96,6 +97,14 @@ public int register(
       return -1; // swallow
     }
 
+    @Override
+    public RegisterSchemaResponse registerWithResponse(
+        final String subject,
+        final ParsedSchema schema,
+        final boolean normalize) throws IOException, RestClientException {
+      return sandboxCacheClient.registerWithResponse(subject, schema, normalize);
+    }
+
     @Deprecated
     @Override
     public Schema getById(final int id) {