From 5e40d1521fc93d4e1a90becfd08188268f5c1fc3 Mon Sep 17 00:00:00 2001 From: Robert Yokota Date: Thu, 17 Oct 2024 06:04:09 -0700 Subject: [PATCH] DGS-18853 Revert change to default rule actions (#3334) (#3345) --- .../schemaregistry/client/rest/entities/Rule.java | 12 ++---------- 1 file changed, 2 insertions(+), 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 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; }