diff --git a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ClassLoaderSafeSchemaRegistryClient.java b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ClassLoaderSafeSchemaRegistryClient.java index 6fa9e49e3b32..fec23afe3aae 100644 --- a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ClassLoaderSafeSchemaRegistryClient.java +++ b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ClassLoaderSafeSchemaRegistryClient.java @@ -102,6 +102,24 @@ public int register(String subject, ParsedSchema schema, boolean normalize) } } + @Override + public RegisterSchemaResponse registerWithResponse(String subject, ParsedSchema schema, boolean normalize, boolean propagateSchemaTags) + throws IOException, RestClientException + { + try (ThreadContextClassLoader _ = new ThreadContextClassLoader(classLoader)) { + return delegate.registerWithResponse(subject, schema, normalize, propagateSchemaTags); + } + } + + @Override + public Collection getAllContexts() + throws IOException, RestClientException + { + try (ThreadContextClassLoader _ = new ThreadContextClassLoader(classLoader)) { + return delegate.getAllContexts(); + } + } + @Override @SuppressWarnings("deprecation") public Schema getByID(int id) diff --git a/pom.xml b/pom.xml index f04641193eac..081fe2126b5e 100644 --- a/pom.xml +++ b/pom.xml @@ -190,7 +190,7 @@ 1.12.0 1.12.773 4.17.0 - 7.5.1 + 7.7.1 100 1.22