updated default schema registry versions

epiphanous · Aug 23, 2021 · c8f7ac7 · c8f7ac7
1 parent db584c2
commit c8f7ac7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala
@@ -282,7 +282,7 @@ class ConfluentSchemaRegistryClient() (implicit
    *   the version to retrieve (defaults to "latest")
    * @return
    */
-  protected def url(subject: String, version: String = "latest"): String =
+  protected def url(subject: String, version: String = "1"): String =
     s"$urlBase/subjects/$subject/versions/$version"
 
 }

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryContext.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryContext.scala
@@ -2,4 +2,4 @@ package io.epiphanous.flinkrunner.avro
 
 case class ConfluentSchemaRegistryContext(
     isKey: Boolean = false,
-    version: String = "latest")
+    version: String = "1")