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
index b7296b01271..fdc5873c681 100644
--- 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;
   }