Update confluent schema registry to 7.7.1

trinodb · Oct 7, 2024 · 9c09b6a · 9c09b6a
1 parent a803861
commit 9c09b6a
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 1 deletion.
diff --git a/...main/java/io/trino/plugin/kafka/schema/confluent/ClassLoaderSafeSchemaRegistryClient.java b/...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<String> 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
@@ -190,7 +190,7 @@
         <dep.avro.version>1.12.0</dep.avro.version>
         <dep.aws-sdk.version>1.12.773</dep.aws-sdk.version>
         <dep.cassandra.version>4.17.0</dep.cassandra.version>
-        <dep.confluent.version>7.5.1</dep.confluent.version>
+        <dep.confluent.version>7.7.1</dep.confluent.version>
         <dep.docker.images.version>100</dep.docker.images.version>
         <dep.drift.version>1.22</dep.drift.version>
         <!-- temporary downgrade due to https://github.com/google/error-prone/issues/4598 -->