only set compatibility on first time registration

kafkajs · Apr 5, 2022 · 5230831 · 5230831
1 parent c3bc207
commit 5230831
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/SchemaRegistry.ts b/src/SchemaRegistry.ts
@@ -112,7 +112,7 @@ export default class SchemaRegistry {
     const helper = helperTypeFromSchemaType(confluentSchema.type)
     const schemaInstance = schemaFromConfluentSchema(confluentSchema, this.options)
     helper.validate(schemaInstance)
-
+    let isFirstTimeRegistration = false
     let subject: ConfluentSubject
     if (userOpts?.subject) {
       subject = {
@@ -134,6 +134,8 @@ export default class SchemaRegistry {
     } catch (error) {
       if (error.status !== 404) {
         throw error
+      } else {
+        isFirstTimeRegistration = true
       }
     }
 
@@ -145,7 +147,7 @@ export default class SchemaRegistry {
       },
     })
 
-    if (compatibility) {
+    if (compatibility && isFirstTimeRegistration) {
       await this.api.Subject.updateConfig({ subject: subject.name, body: { compatibility } })
     }