From 9ad563d3b81d2bb50d89a46059e793436f02b566 Mon Sep 17 00:00:00 2001 From: Walker Carlson <18128741+wcarlson5@users.noreply.github.com> Date: Tue, 16 Nov 2021 14:57:23 -0600 Subject: [PATCH] fix: update client to fix build (#8369) * fix: update client to fix build (cherry picked from commit 6c1f32e1d3f39bc642315fc77c5e152d591a7a09) --- .../registry/DefaultSchemaRegistryClient.java | 15 +++++++++++++++ .../SandboxedSchemaRegistryClientTest.java | 1 + 2 files changed, 16 insertions(+) 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)