diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/CleanupPolicy.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/CleanupPolicy.java index 49db34b8de..bfbfdf9d81 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/CleanupPolicy.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/CleanupPolicy.java @@ -6,7 +6,7 @@ import java.util.Arrays; public enum CleanupPolicy { DELETE("delete"), COMPACT("compact"), - COMPACT_DELETE("compact, delete"), + COMPACT_DELETE("compact,delete"), UNKNOWN("unknown"); private final String cleanUpPolicy; @@ -21,7 +21,7 @@ public enum CleanupPolicy { public static CleanupPolicy fromString(String string) { return Arrays.stream(CleanupPolicy.values()) - .filter(v -> v.cleanUpPolicy.equals(string)) + .filter(v -> v.cleanUpPolicy.equals(string.replace(" ", ""))) .findFirst() .orElseThrow(() -> new IllegalEntityStateException("Unknown cleanup policy value: " + string));