ADAPT1-1599 | Remove exp backoff in registerSchema method

ps-dev · Jul 11, 2024 · 508bfa1 · 508bfa1
1 parent 4ffece2
commit 508bfa1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ingestors/kafka/src/main/scala/hydra/kafka/programs/CreateTopicProgram.scala b/ingestors/kafka/src/main/scala/hydra/kafka/programs/CreateTopicProgram.scala
@@ -44,12 +44,12 @@ final class CreateTopicProgram[F[_]: Bracket[*[_], Throwable]: Sleep: Logger] pr
     val suffixedSubject = subject.value + (if (isKey) "-key" else "-value")
     val registerSchema: F[Option[SchemaVersion]] = {
       schemaRegistry
-        .getVersion(suffixedSubject, schema, useExponentialBackoffRetryPolicy = true)
+        .getVersion(suffixedSubject, schema)
         .attempt
         .map(_.toOption)
         .flatMap { previousSchemaVersion =>
           schemaRegistry.registerSchema(suffixedSubject, schema) *>
-            schemaRegistry.getVersion(suffixedSubject, schema, useExponentialBackoffRetryPolicy = true).map {
+            schemaRegistry.getVersion(suffixedSubject, schema).map {
               newSchemaVersion =>
                 if (previousSchemaVersion.contains(newSchemaVersion)) {
                   None