Revert change to default rule actions (#3334)

confluentinc · Oct 14, 2024 · 7767bb9 · 7767bb9
1 parent 79aded5
commit 7767bb9
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/client/src/main/java/io/confluent/kafka/schemaregistry/client/rest/entities/Rule.java b/client/src/main/java/io/confluent/kafka/schemaregistry/client/rest/entities/Rule.java
@@ -83,16 +83,8 @@ public Rule(@JsonProperty("name") String name,
     this.tags = Collections.unmodifiableSortedSet(sortedTags);
     this.params = Collections.unmodifiableSortedMap(sortedParams);
     this.expr = expr;
-    this.onSuccess = onSuccess != null
-        ? onSuccess
-        : mode == RuleMode.WRITEREAD || mode == RuleMode.UPDOWN
-            ? "NONE,NONE"
-            : "NONE";
-    this.onFailure = onFailure != null
-        ? onFailure
-        : mode == RuleMode.WRITEREAD || mode == RuleMode.UPDOWN
-            ? "ERROR,ERROR"
-            : "ERROR";
+    this.onSuccess = onSuccess;
+    this.onFailure = onFailure;
     this.disabled = disabled;
   }