diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/schema/registry/DefaultSchemaRegistryClient.java b/ksqldb-engine/src/main/java/io/confluent/ksql/schema/registry/DefaultSchemaRegistryClient.java index 46218f556342..87bc36971efd 100644 --- a/ksqldb-engine/src/main/java/io/confluent/ksql/schema/registry/DefaultSchemaRegistryClient.java +++ b/ksqldb-engine/src/main/java/io/confluent/ksql/schema/registry/DefaultSchemaRegistryClient.java @@ -58,6 +58,11 @@ public int register(final String s, final ParsedSchema parsedSchema) { throw configException; } + @Override + public int register(final String s, final ParsedSchema parsedSchema, final boolean normalize) { + throw configException; + } + @Override public int register(final String s, final ParsedSchema parsedSchema, final int i, final int i1) { throw configException; @@ -93,6 +98,11 @@ public int getVersion(final String s, final ParsedSchema parsedSchema) { throw configException; } + @Override + public int getVersion(final String s, final ParsedSchema parsedSchema, final boolean normalize) { + throw configException; + } + @Override public List getAllVersions(final String s) { throw configException; @@ -143,6 +153,11 @@ public int getId(final String s, final ParsedSchema parsedSchema) { throw configException; } + @Override + public int getId(final String s, final ParsedSchema parsedSchema, final boolean normalize) { + throw configException; + } + @Override public List deleteSubject(final String s) { return ImmutableList.of(); diff --git a/ksqldb-engine/src/test/java/io/confluent/ksql/services/SandboxedSchemaRegistryClientTest.java b/ksqldb-engine/src/test/java/io/confluent/ksql/services/SandboxedSchemaRegistryClientTest.java index 001860008c6f..b57268f3890a 100644 --- a/ksqldb-engine/src/test/java/io/confluent/ksql/services/SandboxedSchemaRegistryClientTest.java +++ b/ksqldb-engine/src/test/java/io/confluent/ksql/services/SandboxedSchemaRegistryClientTest.java @@ -55,6 +55,7 @@ public static Collection> getMethodsToTest() { // when adding, ensure you also add a suitable test to SupportedMethods below. .ignore("register", String.class, Schema.class) .ignore("register", String.class, ParsedSchema.class) + .ignore("register", String.class, ParsedSchema.class, boolean.class) .ignore("register", String.class, Schema.class, int.class, int.class) .ignore("register", String.class, ParsedSchema.class, int.class, int.class) .ignore("getLatestSchemaMetadata", String.class)