Replacing ::metadata with ::getByVersion in content converters

RADAR-base · Dec 6, 2024 · 4148a82 · 4148a82
1 parent 476f38d
commit 4148a82
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/radar-commons/src/main/java/org/radarbase/producer/rest/AvroContentConverter.kt b/radar-commons/src/main/java/org/radarbase/producer/rest/AvroContentConverter.kt
@@ -25,17 +25,17 @@ class AvroContentConverter(
 
         return coroutineScope {
             val keySchema = async {
-                schemaRetriever.metadata(
+                schemaRetriever.getByVersion(
                     topic = value.topic.name,
                     ofValue = false,
-                    schema = value.topic.keySchema,
+                    version = -1,
                 )
             }
             val valueSchema = async {
-                schemaRetriever.metadata(
+                schemaRetriever.getByVersion(
                     topic = value.topic.name,
                     ofValue = true,
-                    schema = value.topic.valueSchema,
+                    version = -1,
                 )
             }
             val maker = if (binary) {